You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by pn...@apache.org on 2019/05/07 07:44:29 UTC
[flink] 02/07: [hotfix][kafka,
test] Add missing shutdown call propagation
This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit f487d8ca54dc3de030b3332825e3faa028f6e590
Author: Piotr Nowojski <pi...@gmail.com>
AuthorDate: Thu Feb 7 14:47:11 2019 +0100
[hotfix][kafka,test] Add missing shutdown call propagation
---
.../flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java | 3 ++-
.../flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java | 1 +
2 files changed, 3 insertions(+), 1 deletion(-)
diff --git a/flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java b/flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java
index 40728ba..57dc663 100644
--- a/flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java
+++ b/flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java
@@ -295,7 +295,7 @@ public class KafkaTestEnvironmentImpl extends KafkaTestEnvironment {
}
@Override
- public void shutdown() {
+ public void shutdown() throws Exception {
for (KafkaServer broker : brokers) {
if (broker != null) {
broker.shutdown();
@@ -331,6 +331,7 @@ public class KafkaTestEnvironmentImpl extends KafkaTestEnvironment {
// ignore
}
}
+ super.shutdown();
}
public ZkUtils getZkUtils() {
diff --git a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java
index 90e9e5d..0e9036d 100644
--- a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java
+++ b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java
@@ -359,6 +359,7 @@ public class KafkaTestEnvironmentImpl extends KafkaTestEnvironment {
// ignore
}
}
+ super.shutdown();
}
protected KafkaServer getKafkaServer(int brokerId, File tmpFolder) throws Exception {