Author: daijy
Date: Wed Mar 4 22:22:40 2015
New Revision: 1664170
URL: http://svn.apache.org/r1664170
Log:
PIG-4444: Fix unit test failure TestTezAutoParallelism
Modified:
pig/trunk/CHANGES.txt
pig/trunk/test/org/apache/pig/tez/TestTezAutoParallelism.java
Modified: pig/trunk/CHANGES.txt
URL:
http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1664170&r1=1664169&r2=1664170&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Wed Mar 4 22:22:40 2015
@@ -50,6 +50,8 @@ PIG-4333: Split BigData tests into multi
BUG FIXES
+PIG-4444: Fix unit test failure TestTezAutoParallelism (daijy)
+
PIG-4445: VALUELIST and VALUESET outputSchema does not match actual schema of
data returned when map value schema
is complex (erwaman via daijy)
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=1664170&r1=1664169&r2=1664170&view=diff
==============================================================================
--- pig/trunk/test/org/apache/pig/tez/TestTezAutoParallelism.java (original)
+++ pig/trunk/test/org/apache/pig/tez/TestTezAutoParallelism.java Wed Mar 4
22:22:40 2015
@@ -223,7 +223,7 @@ public class TestTezAutoParallelism {
// skewed join parallelism is 3 originally, increase to 5
pigServer.getPigContext().getProperties().setProperty(PigConfiguration.PIG_NO_SPLIT_COMBINATION,
"true");
pigServer.getPigContext().getProperties().setProperty(MRConfiguration.MAX_SPLIT_SIZE,
"3000");
-
pigServer.getPigContext().getProperties().setProperty(InputSizeReducerEstimator.BYTES_PER_REDUCER_PARAM,
"80000");
+
pigServer.getPigContext().getProperties().setProperty(InputSizeReducerEstimator.BYTES_PER_REDUCER_PARAM,
"40000");
pigServer.registerQuery("A = load '" + INPUT_FILE1 + "' as
(name:chararray, age:int);");
pigServer.registerQuery("B = load '" + INPUT_FILE2 + "' as
(name:chararray, gender:chararray);");
pigServer.registerQuery("C = join A by name, B by name using
'skewed';");
@@ -238,7 +238,7 @@ public class TestTezAutoParallelism {
return false;
}
});
- assertEquals(files.length, 4);
+ assertEquals(files.length, 5);
}
@Test
