You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2019/05/15 11:49:46 UTC
[flink] 01/04: [hotfix][tests] Don't set process variable to null
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 8e5d34d30a47cfbc3fd2515dc1afca1b989eb86f
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Thu May 9 21:38:23 2019 +0200
[hotfix][tests] Don't set process variable to null
Prevents the output from being written in case of failure
---
.../test/recovery/AbstractTaskManagerProcessFailureRecoveryTest.java | 1 -
1 file changed, 1 deletion(-)
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 9dd4542..897fab1 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
@@ -172,7 +172,6 @@ public abstract class AbstractTaskManagerProcessFailureRecoveryTest extends Test
// kill one of the previous TaskManagers, triggering a failure and recovery
taskManagerProcess1.destroy();
- taskManagerProcess1 = null;
// we create the marker file which signals the program functions tasks that they can complete
touchFile(new File(coordinateTempDir, PROCEED_MARKER_FILE));