From 280f66e0f80932498fd691561c1ddb47815873f0 Mon Sep 17 00:00:00 2001 From: Danny Chan Date: Mon, 13 Sep 2021 11:41:49 +0800 Subject: [PATCH] [MINOR] Fix the default parallelism of write task (#3649) --- .../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 bdb58e424..3a2e6152d 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 @@ -335,19 +335,19 @@ public class FlinkOptions extends HoodieConfig { .key("write.index_bootstrap.tasks") .intType() .noDefaultValue() - .withDescription("Parallelism of tasks that do index bootstrap, default is the parallelism of the environment"); + .withDescription("Parallelism of tasks that do index bootstrap, default is the parallelism of the execution 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 the parallelism of the environment"); + .withDescription("Parallelism of tasks that do bucket assign, default is the parallelism of the execution environment"); public static final ConfigOption WRITE_TASKS = ConfigOptions .key("write.tasks") .intType() - .noDefaultValue() - .withDescription("Parallelism of tasks that do actual write, default is the parallelism of the environment"); + .defaultValue(4) + .withDescription("Parallelism of tasks that do actual write, default is 4"); public static final ConfigOption WRITE_TASK_MAX_SIZE = ConfigOptions .key("write.task.max.size")