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