You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2017/10/30 23:05:27 UTC
[2/5] flink git commit: [FLINK-7739][kafka-tests] Shutdown
NetworkFailureProxy
[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 <pi...@gmail.com>
Authored: Fri Sep 29 14:45:28 2017 +0200
Committer: Till Rohrmann <tr...@apache.org>
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() {