[flink] branch release-1.11 updated: [FLINK-18468][tests] Harden TaskExecutorITCase.testJobReExecutionAfterTaskExecutorTermination()

[tr...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

trohrmann pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.11 by this push:
     new 7e5504f  [FLINK-18468][tests] Harden TaskExecutorITCase.testJobReExecutionAfterTaskExecutorTermination()
7e5504f is described below

commit 7e5504f01d5b71c79bc686c27b3613d1b30b6fed
Author: Till Rohrmann <tr...@apache.org>
AuthorDate: Fri Jul 3 17:37:00 2020 +0200

    [FLINK-18468][tests] Harden TaskExecutorITCase.testJobReExecutionAfterTaskExecutorTermination()
    
    This commit hardens the TaskExecutorITCase.testJobReExecutionAfterTaskExecutorTermination() by
    resubmitting the job under a new JobID. A JobID identifies a run of a job and should not be
    reused.
    
    This closes #12821.
---
 .../org/apache/flink/runtime/taskexecutor/TaskExecutorITCase.java   | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskExecutorITCase.java b/flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskExecutorITCase.java
index b8104ab..58e6996 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskExecutorITCase.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/TaskExecutorITCase.java
@@ -103,11 +103,11 @@ public class TaskExecutorITCase extends TestLogger {
 
 		miniCluster.startTaskExecutor();
 
+		final JobGraph newJobGraph = createJobGraph(PARALLELISM);
 		BlockingOperator.unblock();
+		miniCluster.submitJob(newJobGraph).get();
 
-		miniCluster.submitJob(jobGraph).get();
-
-		miniCluster.requestJobResult(jobGraph.getJobID()).get();
+		miniCluster.requestJobResult(newJobGraph.getJobID()).get();
 	}
 
 	/**