[hudi] branch master updated: [MINOR] Correct the comment for the parallelism of tasks in FlinkOptions (#3634)

[vinoyang]

This is an automated email from the ASF dual-hosted git repository.

vinoyang 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 512ca42  [MINOR] Correct the comment for the parallelism of tasks in 
FlinkOptions (#3634)
512ca42 is described below

commit 512ca42d14a29e5d8da02198345024f2f83999d9
Author: SteNicholas <programg...@163.com>
AuthorDate: Fri Sep 10 13:42:11 2021 +0800

    [MINOR] Correct the comment for the parallelism of tasks in FlinkOptions 
(#3634)
---
 .../src/main/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 6e0ff52..64b308d 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<Integer> 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<Integer> 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<Double> WRITE_TASK_MAX_SIZE = ConfigOptions
       .key("write.task.max.size")