[hotfix][tests] Properly clean up RescalingITCase and allow it to run in the 
loop


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e7d7ef12
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e7d7ef12
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/e7d7ef12

Branch: refs/heads/master
Commit: e7d7ef1215a8f6bf8a5c7cb9a4627ab9efe7c22b
Parents: 08f7284
Author: Piotr Nowojski <piotr.nowoj...@gmail.com>
Authored: Fri Feb 2 11:21:55 2018 +0100
Committer: Piotr Nowojski <piotr.nowoj...@gmail.com>
Committed: Mon Feb 19 12:21:44 2018 +0100

----------------------------------------------------------------------
 .../java/org/apache/flink/test/checkpointing/RescalingITCase.java   | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/e7d7ef12/flink-tests/src/test/java/org/apache/flink/test/checkpointing/RescalingITCase.java
----------------------------------------------------------------------
diff --git 
a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/RescalingITCase.java
 
b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/RescalingITCase.java
index f874c8c..95763bf 100644
--- 
a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/RescalingITCase.java
+++ 
b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/RescalingITCase.java
@@ -139,6 +139,7 @@ public class RescalingITCase extends TestLogger {
        public static void shutDownExistingCluster() {
                if (cluster != null) {
                        cluster.stop();
+                       cluster = null;
                }
        }
 

Reply via email to