[flink] 03/03: [hotfix][tests] Await broker shutdown during KafkaTestEnvironmentImpl#shutdown

[fpaul]

This is an automated email from the ASF dual-hosted git repository.

fpaul pushed a commit to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 8a939cce93b8b50dda63d1d4fab651b8bb1315d4
Author: Fabian Paul <fabianp...@ververica.com>
AuthorDate: Wed Dec 8 15:49:15 2021 +0100

    [hotfix][tests] Await broker shutdown during 
KafkaTestEnvironmentImpl#shutdown
---
 .../flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java       | 1 +
 1 file changed, 1 insertion(+)

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 5b2f62d..d15214e 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
@@ -375,6 +375,7 @@ public class KafkaTestEnvironmentImpl extends 
KafkaTestEnvironment {
         for (KafkaServer broker : brokers) {
             if (broker != null) {
                 broker.shutdown();
+                broker.awaitShutdown();
             }
         }
         brokers.clear();