From 7dd02bb3b381d20cbdc72ea220861a3a81f3f2aa Mon Sep 17 00:00:00 2001
From: yangjf2019 <highfei2011@outlook.com>
Date: Thu, 13 Feb 2025 14:11:03 +0800
Subject: [PATCH 1/3] [hotfix] [action] Adding line breaks to
 migrate_iceberg_table action prompts

---
 .../flink/action/MigrateIcebergTableActionFactory.java    | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

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 c85559d66b41..893fa0085e4d 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 void printHelp() {
 
         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>,...]");
     }
 }

From 0afac9135c0fb388ee80728bf06766a82b86a24e Mon Sep 17 00:00:00 2001
From: yangjf2019 <highfei2011@outlook.com>
Date: Thu, 13 Feb 2025 14:42:39 +0800
Subject: [PATCH 2/3] fix

---
 docs/content/migration/migration-from-hive.md | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

diff --git a/docs/content/migration/migration-from-hive.md b/docs/content/migration/migration-from-hive.md
index a40079fed84f..b30b2680cc1a 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**

From 073776ec6bbae31eebf1fcf85ab99e4e41ba29cc Mon Sep 17 00:00:00 2001
From: yangjf2019 <highfei2011@outlook.com>
Date: Fri, 14 Feb 2025 10:40:57 +0800
Subject: [PATCH 3/3] adding line breaks to clear_consumers action

---
 .../paimon/flink/action/ClearConsumerActionFactory.java    | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

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 f027c30be184..25e97efbe271 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 void printHelp() {
 
         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:");