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 /bin/flink run \ /path/to/paimon-flink-action-{{< version >}}.jar \ -migrate_table +migrate_table \ --warehouse \ --source_type hive \ --table \ @@ -84,12 +84,13 @@ migrate_table Example: ```bash -/flink run ./paimon-flink-action-{{< version >}}.jar migrate_table \ +/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 /bin/flink run \ /path/to/paimon-flink-action-{{< version >}}.jar \ -migrate_databse +migrate_databse \ --warehouse \ --source_type hive \ --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 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 --database " - + "--table [--including_consumers --excluding_consumers ]"); + " clear_consumers \\\n" + + "--warehouse \\\n" + + "--database \\\n" + + "--table \\\n" + + "[--including_consumers --excluding_consumers ]"); 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 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 " - + "--iceberg_options =[,=,...]" - + "[--catalog_conf = \\\n" + + "--iceberg_options =[,=,...] \\\n" + + "[--catalog_conf ==,=,...]"); } }