[hotfix][kafka,test] Handle shutdownCluster even if it wasn't initial…

…ized Previously null pointer exception thrown from @afterclass shutdown call could hide original underlying issue if there was a failure that prevented kafkaServer from being constructed
Pance · May 7, 2019 · b20e57d · b20e57d
1 parent 39710d3
commit b20e57d
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...r-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestBase.java b/...r-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestBase.java
@@ -167,7 +167,9 @@ protected static void shutdownClusters() throws Exception {
  secureProps.clear();
  }
 
- kafkaServer.shutdown();
+ if (kafkaServer != null) {
+ kafkaServer.shutdown();
+ }
  }
 
  // ------------------------------------------------------------------------