Author: pisong
Date: Wed Jul 23 06:20:05 2008
New Revision: 679086

URL: http://svn.apache.org/viewvc?rev=679086&view=rev
Log:
Fixed type problem in TestStoreOld

Modified:
    incubator/pig/branches/types/test/org/apache/pig/test/TestStoreOld.java

Modified: 
incubator/pig/branches/types/test/org/apache/pig/test/TestStoreOld.java
URL: 
http://svn.apache.org/viewvc/incubator/pig/branches/types/test/org/apache/pig/test/TestStoreOld.java?rev=679086&r1=679085&r2=679086&view=diff
==============================================================================
--- incubator/pig/branches/types/test/org/apache/pig/test/TestStoreOld.java 
(original)
+++ incubator/pig/branches/types/test/org/apache/pig/test/TestStoreOld.java Wed 
Jul 23 06:20:05 2008
@@ -60,7 +60,7 @@
         
         pig.store("A", tmpFile1);
         
-        pig.registerQuery("B = foreach (group A by $0) generate $0, SUM($1);");
+        pig.registerQuery("B = foreach (group A by $0) generate $0, 
SUM($1.$0);");
         pig.store("B", tmpFile2);
         pig.registerQuery("C = load " + tmpFile2 + ";");
         Iterator<Tuple> iter  = pig.openIterator("C");
@@ -78,9 +78,9 @@
     
     public void testStoreWithMultipleMRJobs() throws Exception{
         pig.registerQuery("A = load " + fileName + ";");        
-        pig.registerQuery("B = foreach (group A by $0) generate $0, SUM($1);");
-        pig.registerQuery("C = foreach (group B by $0) generate $0, SUM($1);");
-        pig.registerQuery("D = foreach (group C by $0) generate $0, SUM($1);");
+        pig.registerQuery("B = foreach (group A by $0) generate $0, 
SUM($1.$0);");
+        pig.registerQuery("C = foreach (group B by $0) generate $0, 
SUM($1.$0);");
+        pig.registerQuery("D = foreach (group C by $0) generate $0, 
SUM($1.$0);");
 
         pig.store("D", tmpFile2);
         pig.registerQuery("E = load " + tmpFile2 + ";");


Reply via email to