[FLINK-7739] [tests] Remove unnecessary FlinkMiniCluster#awaitTermination calls
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/185c807d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/185c807d Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/185c807d Branch: refs/heads/master Commit: 185c807d144208aa4061e18fe8f46dfe0e931a15 Parents: f30f91a Author: Till Rohrmann <[email protected]> Authored: Sun Oct 29 15:34:13 2017 +0100 Committer: Till Rohrmann <[email protected]> Committed: Tue Oct 31 00:05:00 2017 +0100 ---------------------------------------------------------------------- .../java/org/apache/flink/test/checkpointing/RescalingITCase.java | 1 - .../java/org/apache/flink/test/checkpointing/SavepointITCase.java | 2 -- 2 files changed, 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/185c807d/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 7c2bb38..40b45f9 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 @@ -140,7 +140,6 @@ public class RescalingITCase extends TestLogger { public static void shutDownExistingCluster() { if (cluster != null) { cluster.stop(); - cluster.awaitTermination(); } } http://git-wip-us.apache.org/repos/asf/flink/blob/185c807d/flink-tests/src/test/java/org/apache/flink/test/checkpointing/SavepointITCase.java ---------------------------------------------------------------------- diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/SavepointITCase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/SavepointITCase.java index 6f33a2f..75f0aa4 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/SavepointITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/SavepointITCase.java @@ -80,7 +80,6 @@ import org.apache.flink.shaded.guava18.com.google.common.collect.Multimap; import akka.actor.ActorRef; import akka.actor.ActorSystem; import akka.testkit.JavaTestKit; - import org.junit.Assert; import org.junit.Rule; import org.junit.Test; @@ -841,7 +840,6 @@ public class SavepointITCase extends TestLogger { cluster.disposeSavepoint(savepointPath); } cluster.stop(); - cluster.awaitTermination(); } }
