diff --git a/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java b/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java index 6e0ff5207..64b308d6f 100644 --- a/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java +++ b/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java @@ -325,19 +325,19 @@ public class FlinkOptions extends HoodieConfig { .key("write.index_bootstrap.tasks") .intType() .noDefaultValue() - .withDescription("Parallelism of tasks that do index bootstrap, default is 4"); + .withDescription("Parallelism of tasks that do index bootstrap, default is the parallelism of the environment"); public static final ConfigOption BUCKET_ASSIGN_TASKS = ConfigOptions .key("write.bucket_assign.tasks") .intType() .noDefaultValue() - .withDescription("Parallelism of tasks that do bucket assign, default is 4"); + .withDescription("Parallelism of tasks that do bucket assign, default is the parallelism of the environment"); public static final ConfigOption WRITE_TASKS = ConfigOptions .key("write.tasks") .intType() - .defaultValue(4) - .withDescription("Parallelism of tasks that do actual write, default is 4"); + .noDefaultValue() + .withDescription("Parallelism of tasks that do actual write, default is the parallelism of the environment"); public static final ConfigOption WRITE_TASK_MAX_SIZE = ConfigOptions .key("write.task.max.size")