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


Reply via email to