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);
         }


Reply via email to