You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by da...@apache.org on 2023/02/09 10:01:02 UTC
[hudi] branch master updated: [MINOR] Description update for Flink Clustering and Compaction configuration (#7887)
This is an automated email from the ASF dual-hosted git repository.
danny0405 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 088d9a061e5 [MINOR] Description update for Flink Clustering and Compaction configuration (#7887)
088d9a061e5 is described below
commit 088d9a061e57c27d76f43b7d7bb5b50d8e5ed42c
Author: voonhous <vo...@gmail.com>
AuthorDate: Thu Feb 9 18:00:53 2023 +0800
[MINOR] Description update for Flink Clustering and Compaction configuration (#7887)
---
.../java/org/apache/hudi/sink/clustering/FlinkClusteringConfig.java | 4 ++--
.../main/java/org/apache/hudi/sink/compact/FlinkCompactionConfig.java | 4 ++--
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/FlinkClusteringConfig.java b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/FlinkClusteringConfig.java
index 739cb29052a..fd5ee76121e 100644
--- a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/FlinkClusteringConfig.java
+++ b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/FlinkClusteringConfig.java
@@ -113,8 +113,8 @@ public class FlinkClusteringConfig extends Configuration {
public static final String SEQ_FIFO = "FIFO";
public static final String SEQ_LIFO = "LIFO";
@Parameter(names = {"--seq"}, description = "Clustering plan execution sequence, two options are supported:\n"
- + "1). FIFO: execute the oldest plan first;\n"
- + "2). LIFO: execute the latest plan first, by default FIFO")
+ + "1). FIFO: execute the oldest plan first, by default FIFO;\n"
+ + "2). LIFO: execute the latest plan first")
public String clusteringSeq = SEQ_FIFO;
@Parameter(names = {"--service"}, description = "Flink Clustering runs in service mode, disable by default")
diff --git a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/FlinkCompactionConfig.java b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/FlinkCompactionConfig.java
index 068c39d838c..13ab8352980 100644
--- a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/FlinkCompactionConfig.java
+++ b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/FlinkCompactionConfig.java
@@ -96,8 +96,8 @@ public class FlinkCompactionConfig extends Configuration {
public static final String SEQ_FIFO = "FIFO";
public static final String SEQ_LIFO = "LIFO";
@Parameter(names = {"--seq"}, description = "Compaction plan execution sequence, two options are supported:\n"
- + "1). FIFO: execute the oldest plan first;\n"
- + "2). LIFO: execute the latest plan first, by default LIFO")
+ + "1). FIFO: execute the oldest plan first, by default FIFO;\n"
+ + "2). LIFO: execute the latest plan first")
public String compactionSeq = SEQ_FIFO;
@Parameter(names = {"--service"}, description = "Flink Compaction runs in service mode, disable by default")