[FLINK-7739][kafka-tests] Shutdown NetworkFailureProxy This closes #4749.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9eb878e9 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/9eb878e9 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/9eb878e9 Branch: refs/heads/master Commit: 9eb878e99021815bec6c033c6d78e16058e7b6a6 Parents: ae50c30 Author: Piotr Nowojski <[email protected]> Authored: Fri Sep 29 14:45:28 2017 +0200 Committer: Till Rohrmann <[email protected]> Committed: Tue Oct 31 00:04:59 2017 +0100 ---------------------------------------------------------------------- .../streaming/connectors/kafka/KafkaTestEnvironmentImpl.java | 3 ++- .../streaming/connectors/kafka/KafkaTestEnvironmentImpl.java | 3 ++- .../streaming/connectors/kafka/KafkaTestEnvironmentImpl.java | 3 ++- 3 files changed, 6 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/9eb878e9/flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java ---------------------------------------------------------------------- diff --git a/flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java b/flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java index d0e935b..72d9cb5 100644 --- a/flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java +++ b/flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java @@ -279,7 +279,7 @@ public class KafkaTestEnvironmentImpl extends KafkaTestEnvironment { } @Override - public void shutdown() { + public void shutdown() throws Exception { for (KafkaServer broker : brokers) { if (broker != null) { broker.shutdown(); @@ -315,6 +315,7 @@ public class KafkaTestEnvironmentImpl extends KafkaTestEnvironment { // ignore } } + super.shutdown(); } public ZkUtils getZkUtils() { http://git-wip-us.apache.org/repos/asf/flink/blob/9eb878e9/flink-connectors/flink-connector-kafka-0.8/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java ---------------------------------------------------------------------- diff --git a/flink-connectors/flink-connector-kafka-0.8/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java b/flink-connectors/flink-connector-kafka-0.8/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java index eb1f57e..d55edbe 100644 --- a/flink-connectors/flink-connector-kafka-0.8/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java +++ b/flink-connectors/flink-connector-kafka-0.8/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java @@ -270,7 +270,7 @@ public class KafkaTestEnvironmentImpl extends KafkaTestEnvironment { } @Override - public void shutdown() { + public void shutdown() throws Exception { if (brokers != null) { for (KafkaServer broker : brokers) { if (broker != null) { @@ -309,6 +309,7 @@ public class KafkaTestEnvironmentImpl extends KafkaTestEnvironment { // ignore } } + super.shutdown(); } @Override http://git-wip-us.apache.org/repos/asf/flink/blob/9eb878e9/flink-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java ---------------------------------------------------------------------- diff --git a/flink-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java b/flink-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java index 26b41e6..e778b73 100644 --- a/flink-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java +++ b/flink-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java @@ -265,7 +265,7 @@ public class KafkaTestEnvironmentImpl extends KafkaTestEnvironment { } @Override - public void shutdown() { + public void shutdown() throws Exception { for (KafkaServer broker : brokers) { if (broker != null) { broker.shutdown(); @@ -302,6 +302,7 @@ public class KafkaTestEnvironmentImpl extends KafkaTestEnvironment { // ignore } } + super.shutdown(); } public ZkUtils getZkUtils() {
