This is an automated email from the ASF dual-hosted git repository.
JingsongLi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
The following commit(s) were added to refs/heads/master by this push:
new 0a084375cf [flink] Fix incorrect argument names in action help
messages (#8612)
0a084375cf is described below
commit 0a084375cf561037d15132900b5353db2b08c9a6
Author: Eunbin Son <[email protected]>
AuthorDate: Wed Jul 15 09:05:13 2026 +0900
[flink] Fix incorrect argument names in action help messages (#8612)
---
.../java/org/apache/paimon/flink/action/CreateTagActionFactory.java | 3 ++-
.../paimon/flink/action/CreateTagFromTimestampActionFactory.java | 2 +-
.../paimon/flink/action/CreateTagFromWatermarkActionFactory.java | 2 +-
.../org/apache/paimon/flink/action/ExpireChangelogsActionFactory.java | 2 +-
.../org/apache/paimon/flink/action/ExpirePartitionsActionFactory.java | 1 -
.../org/apache/paimon/flink/action/ExpireSnapshotsActionFactory.java | 2 +-
.../java/org/apache/paimon/flink/action/RenameTagActionFactory.java | 2 ++
.../apache/paimon/flink/action/RollbackToTimestampActionFactory.java | 2 +-
8 files changed, 9 insertions(+), 7 deletions(-)
diff --git
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CreateTagActionFactory.java
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CreateTagActionFactory.java
index 0f5968e134..81171d167d 100644
---
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CreateTagActionFactory.java
+++
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CreateTagActionFactory.java
@@ -54,7 +54,8 @@ public class CreateTagActionFactory extends
CreateOrReplaceTagActionFactory {
+ "--database <database_name> \\\n"
+ "--table <table_name> \\\n"
+ "--tag_name <tag_name> \\\n"
- + "[--snapshot <snapshot_id>]");
+ + "[--snapshot <snapshot_id>] \\\n"
+ + "[--time_retained <time_retained>]");
System.out.println();
}
}
diff --git
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CreateTagFromTimestampActionFactory.java
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CreateTagFromTimestampActionFactory.java
index 082c0ec62d..658f3e03f0 100644
---
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CreateTagFromTimestampActionFactory.java
+++
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CreateTagFromTimestampActionFactory.java
@@ -65,7 +65,7 @@ public class CreateTagFromTimestampActionFactory implements
ActionFactory {
+ "--table <table_name> \\\n"
+ "--tag <tag> \\\n"
+ "--timestamp <timestamp> \\\n"
- + "[--timeRetained <duration>] \\\n"
+ + "[--time_retained <duration>] \\\n"
+ "[--options <key>=<value>,<key>=<value>,...]");
}
}
diff --git
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CreateTagFromWatermarkActionFactory.java
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CreateTagFromWatermarkActionFactory.java
index 070746a432..1f4e5b1f92 100644
---
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CreateTagFromWatermarkActionFactory.java
+++
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CreateTagFromWatermarkActionFactory.java
@@ -68,7 +68,7 @@ public class CreateTagFromWatermarkActionFactory implements
ActionFactory {
+ "--table <table_name> \\\n"
+ "--tag <tag> \\\n"
+ "--watermark <watermark> \\\n"
- + "[--timeRetained <duration>] \\\n"
+ + "[--time_retained <duration>] \\\n"
+ "[--options <key>=<value>,<key>=<value>,...]");
}
}
diff --git
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ExpireChangelogsActionFactory.java
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ExpireChangelogsActionFactory.java
index 04f85d6b74..be31c717c4 100644
---
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ExpireChangelogsActionFactory.java
+++
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ExpireChangelogsActionFactory.java
@@ -75,7 +75,7 @@ public class ExpireChangelogsActionFactory implements
ActionFactory {
+ "--retain_max <max> \\\n"
+ "--retain_min <min> \\\n"
+ "--older_than <older_than> \\\n"
- + "--max_delete <max_delete> \\\n"
+ + "--max_deletes <max_deletes> \\\n"
+ "--delete_all <delete_all>");
}
}
diff --git
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ExpirePartitionsActionFactory.java
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ExpirePartitionsActionFactory.java
index 52e8e097f2..7e4df1311b 100644
---
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ExpirePartitionsActionFactory.java
+++
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ExpirePartitionsActionFactory.java
@@ -58,7 +58,6 @@ public class ExpirePartitionsActionFactory implements
ActionFactory {
+ "--warehouse <warehouse_path> \\\n"
+ "--database <database_name> \\\n"
+ "--table <table_name> \\\n"
- + "--tag_name <tag_name> \\\n"
+ "--expiration_time <expiration_time> \\\n"
+ "--timestamp_formatter <timestamp_formatter> \\\n"
+ "[--timestamp_pattern <timestamp_pattern>] \\\n"
diff --git
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ExpireSnapshotsActionFactory.java
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ExpireSnapshotsActionFactory.java
index 91628c2e37..5b49d20881 100644
---
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ExpireSnapshotsActionFactory.java
+++
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ExpireSnapshotsActionFactory.java
@@ -77,6 +77,6 @@ public class ExpireSnapshotsActionFactory implements
ActionFactory {
+ "--retain_max <max> \\\n"
+ "--retain_min <min> \\\n"
+ "--older_than <older_than> \\\n"
- + "--max_delete <max_delete>");
+ + "--max_deletes <max_deletes>");
}
}
diff --git
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/RenameTagActionFactory.java
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/RenameTagActionFactory.java
index 81006adbf0..e6a734ab62 100644
---
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/RenameTagActionFactory.java
+++
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/RenameTagActionFactory.java
@@ -54,6 +54,8 @@ public class RenameTagActionFactory implements ActionFactory {
System.out.println(
" rename_tag \\\n"
+ "--warehouse <warehouse_path> \\\n"
+ + "--database <database_name> \\\n"
+ + "--table <table_name> \\\n"
+ "--tag_name <tag_name> \\\n"
+ "--target_tag_name <target_tag_name>");
System.out.println();
diff --git
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/RollbackToTimestampActionFactory.java
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/RollbackToTimestampActionFactory.java
index 4aaddf8a90..1f65b533ae 100644
---
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/RollbackToTimestampActionFactory.java
+++
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/RollbackToTimestampActionFactory.java
@@ -52,7 +52,7 @@ public class RollbackToTimestampActionFactory implements
ActionFactory {
System.out.println("Syntax:");
System.out.println(
- " rollback_to \\\n"
+ " rollback_to_timestamp \\\n"
+ "--warehouse <warehouse_path> \\\n"
+ "--database <database_name> \\\n"
+ "--table <table_name> \\\n"
