From 1e08fd860bfeffdc3461066f36a4a5dd38a99098 Mon Sep 17 00:00:00 2001 From: Jonathan Eagles Date: Thu, 16 May 2024 15:57:32 -0500 Subject: [PATCH 1/2] TEZ-4565. TestAnalyzer subtest testInternalPreemption is flaky --- .../src/test/java/org/apache/tez/analyzer/TestAnalyzer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tez-tools/analyzers/job-analyzer/src/test/java/org/apache/tez/analyzer/TestAnalyzer.java b/tez-tools/analyzers/job-analyzer/src/test/java/org/apache/tez/analyzer/TestAnalyzer.java index 606b7e3cd7..42197bfc33 100644 --- a/tez-tools/analyzers/job-analyzer/src/test/java/org/apache/tez/analyzer/TestAnalyzer.java +++ b/tez-tools/analyzers/job-analyzer/src/test/java/org/apache/tez/analyzer/TestAnalyzer.java @@ -681,7 +681,7 @@ private List testInternalPreemption() throws Exception { createStep("v2 : 00000[01]_1", CriticalPathDependency.OUTPUT_RECREATE_DEPENDENCY), createStep("v1 : 000000_1", CriticalPathDependency.OUTPUT_RECREATE_DEPENDENCY, null, Collections.singletonList("preemption of v3")), - createStep("v2 : 00000[01]_1", CriticalPathDependency.DATA_DEPENDENCY), + createStep("v2 : 00000[01]_[1]", CriticalPathDependency.DATA_DEPENDENCY), createStep("v3 : 000000_1", CriticalPathDependency.DATA_DEPENDENCY) }; From 6fb27d0ce64a175f4cd275382f4f2fb8b7b3f426 Mon Sep 17 00:00:00 2001 From: Jonathan Eagles Date: Thu, 16 May 2024 18:40:26 -0500 Subject: [PATCH 2/2] TEZ-4565. TestAnalyzer subtest testInternalPreemption is flaky --- .../src/test/java/org/apache/tez/analyzer/TestAnalyzer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tez-tools/analyzers/job-analyzer/src/test/java/org/apache/tez/analyzer/TestAnalyzer.java b/tez-tools/analyzers/job-analyzer/src/test/java/org/apache/tez/analyzer/TestAnalyzer.java index 42197bfc33..0d59470faa 100644 --- a/tez-tools/analyzers/job-analyzer/src/test/java/org/apache/tez/analyzer/TestAnalyzer.java +++ b/tez-tools/analyzers/job-analyzer/src/test/java/org/apache/tez/analyzer/TestAnalyzer.java @@ -681,7 +681,7 @@ private List testInternalPreemption() throws Exception { createStep("v2 : 00000[01]_1", CriticalPathDependency.OUTPUT_RECREATE_DEPENDENCY), createStep("v1 : 000000_1", CriticalPathDependency.OUTPUT_RECREATE_DEPENDENCY, null, Collections.singletonList("preemption of v3")), - createStep("v2 : 00000[01]_[1]", CriticalPathDependency.DATA_DEPENDENCY), + createStep("v2 : 00000[01]_[12]", CriticalPathDependency.DATA_DEPENDENCY), createStep("v3 : 000000_1", CriticalPathDependency.DATA_DEPENDENCY) };