You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fp...@apache.org on 2022/01/26 08:55:13 UTC
[flink] 02/02: [hotfix] fix a typo in KafkaTestBase
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 <de...@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");