From 512ca42d14a29e5d8da02198345024f2f83999d9 Mon Sep 17 00:00:00 2001 From: SteNicholas Date: Fri, 10 Sep 2021 13:42:11 +0800 Subject: [PATCH] [MINOR] Correct the comment for the parallelism of tasks in FlinkOptions (#3634) --- .../java/org/apache/hudi/configuration/FlinkOptions.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) 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")