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 2011/01/24 19:45:04 UTC
svn commit: r1062920 - in /pig/trunk: CHANGES.txt
test/org/apache/pig/test/TestEvalPipeline2.java
Author: daijy
Date: Mon Jan 24 18:45:04 2011
New Revision: 1062920
URL: http://svn.apache.org/viewvc?rev=1062920&view=rev
Log:
PIG-313: Error handling aggregate of a computation
Modified:
pig/trunk/CHANGES.txt
pig/trunk/test/org/apache/pig/test/TestEvalPipeline2.java
Modified: pig/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1062920&r1=1062919&r2=1062920&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Mon Jan 24 18:45:04 2011
@@ -86,6 +86,8 @@ PIG-1696: Performance: Use System.arrayc
BUG FIXES
+PIG-313: Error handling aggregate of a computation (daijy)
+
PIG-496: project of bags from complex data causes failures (daijy)
PIG-730: problem combining schema from a union of several LOAD expressions, with a nested bag inside the schema (daijy)
Modified: pig/trunk/test/org/apache/pig/test/TestEvalPipeline2.java
URL: http://svn.apache.org/viewvc/pig/trunk/test/org/apache/pig/test/TestEvalPipeline2.java?rev=1062920&r1=1062919&r2=1062920&view=diff
==============================================================================
--- pig/trunk/test/org/apache/pig/test/TestEvalPipeline2.java (original)
+++ pig/trunk/test/org/apache/pig/test/TestEvalPipeline2.java Mon Jan 24 18:45:04 2011
@@ -1198,4 +1198,22 @@ public class TestEvalPipeline2 extends T
assertTrue(t.toString().contains("(2,3,1,2)"));
assertFalse(iter.hasNext());
}
+
+ // See PIG-1785
+ @Test
+ public void testAddingTwoBag() throws Exception{
+ pigServer.registerQuery("a = load '1.txt' as (name:chararray, age:int, gpa:double);");
+ pigServer.registerQuery("b = group a by name;");
+ pigServer.registerQuery("c = foreach b generate group, SUM(a.age*a.gpa);");
+
+ try {
+ pigServer.openIterator("c");
+ } catch (Exception e) {
+ PigException pe = LogUtils.getPigException(e);
+ assertTrue(pe.getErrorCode()==1039);
+ assertTrue(pe.getMessage().contains("incompatible types"));
+ return;
+ }
+ fail();
+ }
}