[flink] 03/04: [FLINK-12111][tests] Wait until TM has shut down

[ch...@apache.org]

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

chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 294915e3e057886fef39528c5e1e72582ea1f4b8
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Thu May 9 21:38:56 2019 +0200

    [FLINK-12111][tests] Wait until TM has shut down
    
    Prevents theoretical scenarios where the job can finish because the destroy() command takes a while to take effect.
---
 .../test/recovery/AbstractTaskManagerProcessFailureRecoveryTest.java     | 1 +
 1 file changed, 1 insertion(+)

diff --git a/flink-tests/src/test/java/org/apache/flink/test/recovery/AbstractTaskManagerProcessFailureRecoveryTest.java b/flink-tests/src/test/java/org/apache/flink/test/recovery/AbstractTaskManagerProcessFailureRecoveryTest.java
index d72507d..26840e7 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/recovery/AbstractTaskManagerProcessFailureRecoveryTest.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/recovery/AbstractTaskManagerProcessFailureRecoveryTest.java
@@ -171,6 +171,7 @@ public abstract class AbstractTaskManagerProcessFailureRecoveryTest extends Test
 
 			// kill one of the previous TaskManagers, triggering a failure and recovery
 			taskManagerProcess1.destroy();
+			waitForShutdown("TaskManager 1", taskManagerProcess1);
 
 			// we create the marker file which signals the program functions tasks that they can complete
 			touchFile(new File(coordinateTempDir, PROCEED_MARKER_FILE));