Author: knoguchi Date: Sun Oct 16 17:52:31 2022 New Revision: 1904623 URL: http://svn.apache.org/viewvc?rev=1904623&view=rev Log: PIG-5430: TestTezGraceParallelism failing due to tez log change (knoguchi)
Modified: pig/trunk/CHANGES.txt pig/trunk/test/org/apache/pig/tez/TestTezGraceParallelism.java Modified: pig/trunk/CHANGES.txt URL: http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1904623&r1=1904622&r2=1904623&view=diff ============================================================================== --- pig/trunk/CHANGES.txt (original) +++ pig/trunk/CHANGES.txt Sun Oct 16 17:52:31 2022 @@ -116,6 +116,8 @@ OPTIMIZATIONS BUG FIXES +PIG-5430: TestTezGraceParallelism failing due to tez log change (knoguchi) + PIG-5406: TestJoinLocal imports org.python.google.common.collect.Lists instead of org.google.common.collect.Lists (rohini) PIG-5425: Pig 0.15 and later don't set context signature correctly (jtolar via rohini) Modified: pig/trunk/test/org/apache/pig/tez/TestTezGraceParallelism.java URL: http://svn.apache.org/viewvc/pig/trunk/test/org/apache/pig/tez/TestTezGraceParallelism.java?rev=1904623&r1=1904622&r2=1904623&view=diff ============================================================================== --- pig/trunk/test/org/apache/pig/tez/TestTezGraceParallelism.java (original) +++ pig/trunk/test/org/apache/pig/tez/TestTezGraceParallelism.java Sun Oct 16 17:52:31 2022 @@ -141,9 +141,9 @@ public class TestTezGraceParallelism { Util.checkQueryOutputsAfterSort(iter, expectedResults); assertTrue(writer.toString().contains("Initialize parallelism for scope-52 to 18")); assertTrue(writer.toString().contains("Initialize parallelism for scope-56 to 7")); - assertTrue(writer.toString().contains("Reduce auto parallelism for vertex: scope-49 to 1 from 2")); - assertTrue(writer.toString().contains("Reduce auto parallelism for vertex: scope-52 to 1 from 18")); - assertTrue(writer.toString().contains("Reduce auto parallelism for vertex: scope-56 to 1 from 7")); + assertTrue(writer.toString().contains("Reducing auto parallelism for vertex: scope-49 from 2 to 1")); + assertTrue(writer.toString().contains("Reducing auto parallelism for vertex: scope-52 from 18 to 1")); + assertTrue(writer.toString().contains("Reducing auto parallelism for vertex: scope-56 from 7 to 1")); } finally { Util.removeLogAppender("testDecreaseParallelism", PigGraceShuffleVertexManager.class, ShuffleVertexManager.class); } @@ -183,7 +183,7 @@ public class TestTezGraceParallelism { System.out.println(writer.toString()); assertTrue(writer.toString().contains("Initialize parallelism for scope-64 to 45")); // There are randomness in which task finishes first, so the auto parallelism could result different result - assertTrue(Pattern.compile("Reduce auto parallelism for vertex: scope-64 to (\\d+)* from 45").matcher(writer.toString()).find()); + assertTrue(Pattern.compile("Reducing auto parallelism for vertex: scope-64 from 45 to (\\d+)*").matcher(writer.toString()).find()); } finally { Util.removeLogAppender("testIncreaseParallelism", PigGraceShuffleVertexManager.class, ShuffleVertexManager.class); }