You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sr...@apache.org on 2018/02/19 14:08:25 UTC
[32/35] flink git commit: [hotfix][tests] Properly clean up
RescalingITCase and allow it to run in the loop
[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 <pi...@gmail.com>
Authored: Fri Feb 2 11:21:55 2018 +0100
Committer: Piotr Nowojski <pi...@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;
}
}