You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by da...@apache.org on 2012/04/08 09:59:15 UTC
svn commit: r1310961 -
/pig/branches/branch-0.10/test/org/apache/pig/test/TestUDF.java
Author: daijy
Date: Sun Apr 8 07:59:15 2012
New Revision: 1310961
URL: http://svn.apache.org/viewvc?rev=1310961&view=rev
Log:
Fix TestUDF failure
Modified:
pig/branches/branch-0.10/test/org/apache/pig/test/TestUDF.java
Modified: pig/branches/branch-0.10/test/org/apache/pig/test/TestUDF.java
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.10/test/org/apache/pig/test/TestUDF.java?rev=1310961&r1=1310960&r2=1310961&view=diff
==============================================================================
--- pig/branches/branch-0.10/test/org/apache/pig/test/TestUDF.java (original)
+++ pig/branches/branch-0.10/test/org/apache/pig/test/TestUDF.java Sun Apr 8 07:59:15 2012
@@ -208,7 +208,7 @@ public class TestUDF extends TestCase {
String query = "DEFINE BasLCWC " + pref + "BasicLongCountWithConstructor('5');";
query += "DEFINE AccLCWC " + pref +" AccLongCountWithConstructor('5');";
query += "DEFINE AlgLCWC " + pref + "AlgLongCountWithConstructor('5');";
- query += "A = load '" + input + "' as (x:int);";
+ query += "A = load '" + input + "' as (x:long);";
query += "B = foreach (group A all) generate ";
for (String s : Arrays.copyOfRange(udfs, i, udfs.length - 1)) {
query += s + "(A),";