pig-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From roh...@apache.org
Subject svn commit: r1700911 - /pig/trunk/test/org/apache/pig/tez/TestTezAutoParallelism.java
Date Wed, 02 Sep 2015 21:49:24 GMT
Author: rohini
Date: Wed Sep  2 21:49:24 2015
New Revision: 1700911

URL: http://svn.apache.org/r1700911
Log:
Fix test failure from PIG-4657: [Pig on Tez] Optimize GroupBy and Distinct key comparison

Modified:
    pig/trunk/test/org/apache/pig/tez/TestTezAutoParallelism.java

Modified: pig/trunk/test/org/apache/pig/tez/TestTezAutoParallelism.java
URL: http://svn.apache.org/viewvc/pig/trunk/test/org/apache/pig/tez/TestTezAutoParallelism.java?rev=1700911&r1=1700910&r2=1700911&view=diff
==============================================================================
--- pig/trunk/test/org/apache/pig/tez/TestTezAutoParallelism.java (original)
+++ pig/trunk/test/org/apache/pig/tez/TestTezAutoParallelism.java Wed Sep  2 21:49:24 2015
@@ -344,11 +344,11 @@ public class TestTezAutoParallelism {
                     + "D = group C2 by group;"
                     + "E = foreach D generate group, COUNT(C2.A::name);"
                     + "F = order E by $0;"
-                    + "STORE E into '" + outputDir + "/finalout';";
+                    + "STORE F into '" + outputDir + "/finalout';";
             String log = testIncreaseIntermediateParallelism(script, outputDir, false);
             // Parallelism of C1 should be increased. C2 will not be increased due to order
by
             assertEquals(1, StringUtils.countMatches(log, "Increased requested parallelism"));
-            assertTrue(log.contains("Increased requested parallelism of scope-63 to 10"));
+            assertTrue(log.contains("Increased requested parallelism of scope-65 to 10"));
         } finally {
             pigServer.setDefaultParallel(-1);
         }



Mime
View raw message