This is an automated email from the ASF dual-hosted git repository.
zhangyue19921010 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new c2f78d46f44d [HUDI-9783] fix wrong descriptioin of partitioner in
FlinkOptions (#13839)
c2f78d46f44d is described below
commit c2f78d46f44de9f59c359a491f30356bcb634c8a
Author: fhan <[email protected]>
AuthorDate: Thu Sep 4 17:47:47 2025 +0800
[HUDI-9783] fix wrong descriptioin of partitioner in FlinkOptions (#13839)
Co-authored-by: fhan <[email protected]>
---
.../src/main/java/org/apache/hudi/configuration/FlinkOptions.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java
index 4c2b81c36d65..7ba63278497e 100644
---
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java
+++
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java
@@ -135,13 +135,13 @@ public class FlinkOptions extends HoodieConfig {
.defaultValue("")
.withDescription("Insert partitioner to use aiming to re-balance records
and reducing small file number "
+ "in the scenario of multi-level partitioning. For example
dt/hour/eventID"
- + "Currently support
org.apache.hudi.sink.partitioner.DefaultInsertPartitioner");
+ + "Currently support
org.apache.hudi.sink.partitioner.GroupedInsertPartitioner");
public static final ConfigOption<Integer> DEFAULT_PARALLELISM_PER_PARTITION
= ConfigOptions
.key("write.insert.partitioner.default_parallelism_per_partition")
.intType()
.defaultValue(30)
- .withDescription("The parallelism to use in each partition when using
DefaultInsertPartitioner.");
+ .withDescription("The parallelism to use in each partition when using
GroupedInsertPartitioner.");
@AdvancedConfig
public static final ConfigOption<String> RECORD_MERGER_IMPLS = ConfigOptions
