[hotfix][flip6] Only create new terminationFuture if MiniCluster is running
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cb1224bf Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cb1224bf Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/cb1224bf Branch: refs/heads/release-1.5 Commit: cb1224bf77cea86d87a990c6b0c9c79a3eda6ac8 Parents: eb666d8 Author: gyao <[email protected]> Authored: Fri Mar 16 06:57:24 2018 +0100 Committer: Till Rohrmann <[email protected]> Committed: Sun Mar 18 18:55:20 2018 +0100 ---------------------------------------------------------------------- .../java/org/apache/flink/runtime/minicluster/MiniCluster.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/cb1224bf/flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java b/flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java index d660c67..74aa388 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java @@ -217,9 +217,6 @@ public class MiniCluster implements JobExecutorService, AutoCloseableAsync { LOG.info("Starting Flink Mini Cluster"); LOG.debug("Using configuration {}", miniClusterConfiguration); - // create a new termination future - terminationFuture = new CompletableFuture<>(); - final Configuration configuration = miniClusterConfiguration.getConfiguration(); final Time rpcTimeout = miniClusterConfiguration.getRpcTimeout(); final int numTaskManagers = miniClusterConfiguration.getNumTaskManagers(); @@ -384,6 +381,9 @@ public class MiniCluster implements JobExecutorService, AutoCloseableAsync { throw e; } + // create a new termination future + terminationFuture = new CompletableFuture<>(); + // now officially mark this as running running = true;
