Skip to content

Commit 36be287

Browse files
authored
[MINOR] Fix typo,'Kakfa' corrected to 'Kafka' & 'parquest' corrected to 'parquet' (apache#3717)
1 parent 7e887b5 commit 36be287

File tree

3 files changed

+4
-4
lines changed

3 files changed

+4
-4
lines changed

hudi-common/src/main/java/org/apache/hudi/common/config/ConfigGroups.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,7 @@ public static String getDescription(Names names) {
7474
+ "Hudi stats and metrics.";
7575
break;
7676
case KAFKA_CONNECT:
77-
description = "These set of configs are used for Kakfa Connect Sink Connector for writing Hudi Tables";
77+
description = "These set of configs are used for Kafka Connect Sink Connector for writing Hudi Tables";
7878
break;
7979
default:
8080
description = "Please fill in the description for Config Group Name: " + names.name;

hudi-kafka-connect/src/main/java/org/apache/hudi/connect/writers/KafkaConnectConfigs.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@
3636
@Immutable
3737
@ConfigClassProperty(name = "Kafka Sink Connect Configurations",
3838
groupName = ConfigGroups.Names.KAFKA_CONNECT,
39-
description = "Configurations for Kakfa Connect Sink Connector for Hudi.")
39+
description = "Configurations for Kafka Connect Sink Connector for Hudi.")
4040
public class KafkaConnectConfigs extends HoodieConfig {
4141

4242
public static final String KAFKA_VALUE_CONVERTER = "value.converter";

hudi-utilities/src/test/java/org/apache/hudi/utilities/functional/TestHoodieDeltaStreamer.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -1514,8 +1514,8 @@ private void testDeltaStreamerTransitionFromParquetToKafkaSource(boolean autoRes
15141514

15151515
prepareParquetDFSSource(true, false, "source_uber.avsc", "target_uber.avsc", PROPS_FILENAME_TEST_PARQUET,
15161516
PARQUET_SOURCE_ROOT, false);
1517-
// delta streamer w/ parquest source
1518-
String tableBasePath = dfsBasePath + "/test_dfs_to_kakfa" + testNum;
1517+
// delta streamer w/ parquet source
1518+
String tableBasePath = dfsBasePath + "/test_dfs_to_kafka" + testNum;
15191519
HoodieDeltaStreamer deltaStreamer = new HoodieDeltaStreamer(
15201520
TestHelpers.makeConfig(tableBasePath, WriteOperationType.INSERT, ParquetDFSSource.class.getName(),
15211521
Collections.EMPTY_LIST, PROPS_FILENAME_TEST_PARQUET, false,

0 commit comments

Comments
 (0)