[flink] 02/02: [hotfix] fix a typo in KafkaTestBase

[fpaul]

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

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

commit 928d6569de10732bb7f5f84009d88d3daf643f43
Author: dengziming <dengzim...@growingio.com>
AuthorDate: Fri Dec 24 10:53:32 2021 +0800

    [hotfix] fix a typo in KafkaTestBase
---
 .../org/apache/flink/streaming/connectors/kafka/KafkaTestBase.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestBase.java
 
b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestBase.java
index 5c1aa25..5246242 100644
--- 
a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestBase.java
+++ 
b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestBase.java
@@ -152,7 +152,7 @@ public abstract class KafkaTestBase extends TestLogger {
 
     public static void startClusters(KafkaTestEnvironment.Config 
environmentConfig)
             throws Exception {
-        kafkaServer = constructKafkaTestEnvionment();
+        kafkaServer = constructKafkaTestEnvironment();
 
         LOG.info("Starting KafkaTestBase.prepare() for Kafka " + 
kafkaServer.getVersion());
 
@@ -171,7 +171,7 @@ public abstract class KafkaTestBase extends TestLogger {
         }
     }
 
-    public static KafkaTestEnvironment constructKafkaTestEnvionment() throws 
Exception {
+    public static KafkaTestEnvironment constructKafkaTestEnvironment() throws 
Exception {
         Class<?> clazz =
                 Class.forName(
                         
"org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl");