(paimon) branch master updated: [hotfix] [doc] [action] Adding line breaks to action and fix document for migration (#5071)

[lzljs3620320]

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

lzljs3620320 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 252513403e [hotfix] [doc] [action] Adding line breaks to action and 
fix document for migration (#5071)
252513403e is described below

commit 252513403e3e96940aa778997201ac6dd0a52338
Author: yangjf2019 <54518670+yangjf2...@users.noreply.github.com>
AuthorDate: Thu Feb 20 15:12:57 2025 +0800

    [hotfix] [doc] [action] Adding line breaks to action and fix document for 
migration (#5071)
---
 docs/content/migration/migration-from-hive.md                 | 11 ++++++-----
 .../paimon/flink/action/ClearConsumerActionFactory.java       |  7 +++++--
 .../paimon/flink/action/MigrateIcebergTableActionFactory.java |  8 ++++----
 3 files changed, 15 insertions(+), 11 deletions(-)

diff --git a/docs/content/migration/migration-from-hive.md 
b/docs/content/migration/migration-from-hive.md
index a40079fed8..b30b2680cc 100644
--- a/docs/content/migration/migration-from-hive.md
+++ b/docs/content/migration/migration-from-hive.md
@@ -74,7 +74,7 @@ If your flink version is below 1.17, you can use flink action 
to achieve this:
 ```bash
 <FLINK_HOME>/bin/flink run \
 /path/to/paimon-flink-action-{{< version >}}.jar \
-migrate_table
+migrate_table \
 --warehouse <warehouse-path> \
 --source_type hive \
 --table <database.table-name> \
@@ -84,12 +84,13 @@ migrate_table
 
 Example:
 ```bash
-<FLINK_HOME>/flink run ./paimon-flink-action-{{< version >}}.jar migrate_table 
\
+<FLINK_HOME>/flink run ./paimon-flink-action-{{< version >}}.jar \
+migrate_table \
 --warehouse /path/to/warehouse \
 --catalog_conf uri=thrift://localhost:9083 \
 --catalog_conf metastore=hive \
 --source_type hive \
---table default.hive_or_paimon \
+--table default.hive_or_paimon
 ```
 
 **Migrate Hive Database**
@@ -123,7 +124,7 @@ If your flink version is below 1.17, you can use flink 
action to achieve this:
 ```bash
 <FLINK_HOME>/bin/flink run \
 /path/to/paimon-flink-action-{{< version >}}.jar \
-migrate_databse
+migrate_databse \
 --warehouse <warehouse-path> \
 --source_type hive \
 --database <database> \
@@ -138,7 +139,7 @@ Example:
 --catalog_conf uri=thrift://localhost:9083 \
 --catalog_conf metastore=hive \
 --source_type hive \
---database default \
+--database default
 ```
 
 **Migrate Hive File**
diff --git 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ClearConsumerActionFactory.java
 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ClearConsumerActionFactory.java
index f027c30be1..25e97efbe2 100644
--- 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ClearConsumerActionFactory.java
+++ 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ClearConsumerActionFactory.java
@@ -60,8 +60,11 @@ public class ClearConsumerActionFactory implements 
ActionFactory {
 
         System.out.println("Syntax:");
         System.out.println(
-                "  clear_consumers --warehouse <warehouse_path> --database 
<database_name> "
-                        + "--table <table_name> [--including_consumers 
<including_pattern> --excluding_consumers <excluding_pattern>]");
+                "  clear_consumers \\\n"
+                        + "--warehouse <warehouse_path> \\\n"
+                        + "--database <database_name> \\\n"
+                        + "--table <table_name> \\\n"
+                        + "[--including_consumers <including_pattern> 
--excluding_consumers <excluding_pattern>]");
 
         System.out.println();
         System.out.println("Note:");
diff --git 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/MigrateIcebergTableActionFactory.java
 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/MigrateIcebergTableActionFactory.java
index c85559d66b..893fa0085e 100644
--- 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/MigrateIcebergTableActionFactory.java
+++ 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/MigrateIcebergTableActionFactory.java
@@ -61,10 +61,10 @@ public class MigrateIcebergTableActionFactory implements 
ActionFactory {
 
         System.out.println("Syntax:");
         System.out.println(
-                "  migrate_iceberg_table"
-                        + "--table <database.table_name> "
-                        + "--iceberg_options <key>=<value>[,<key>=<value>,...]"
-                        + "[--catalog_conf <key>=<value] "
+                "  migrate_iceberg_table \\\n"
+                        + "--table <database.table_name> \\\n"
+                        + "--iceberg_options <key>=<value>[,<key>=<value>,...] 
\\\n"
+                        + "[--catalog_conf <key>=<value] \\\n"
                         + "[--options <key>=<value>,<key>=<value>,...]");
     }
 }