You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by vi...@apache.org on 2021/09/10 05:42:27 UTC
[hudi] branch master updated: [MINOR] Correct the comment for the
parallelism of tasks in FlinkOptions (#3634)
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 <pr...@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")