fix comment

apache · Dec 1, 2023 · b23f09d · b23f09d
1 parent f92a122
commit b23f09d
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 6 deletions.
diff --git a/docs/content/migration/migration-from-hive.md b/docs/content/migration/migration-from-hive.md
@@ -74,7 +74,7 @@ migrate_table
 --src-type hive \
 --table <database.table-name> \
 [--catalog-conf <paimon-catalog-conf> [--catalog-conf <paimon-catalog-conf> ...]] \
-[--table-conf <paimon-table-sink-conf> [--table-conf <paimon-table-sink-conf> ...]]
+[--options <paimon-table-conf  [,paimon-table-conf ...]> ]
 ```
 
 Example:

diff --git a/...-flink-common/src/main/java/org/apache/paimon/flink/action/MigrateTableActionFactory.java b/...-flink-common/src/main/java/org/apache/paimon/flink/action/MigrateTableActionFactory.java
@@ -39,7 +39,7 @@ public Optional<Action> create(MultipleParameterTool params) {
         String connector = params.get("src-type");
         String sourceHiveTable = params.get("table");
         Map<String, String> catalogConfig = optionalConfigMap(params, "catalog-conf");
-        String tableConf = params.get("tblproperties");
+        String tableConf = params.get("options");
 
         MigrateTableAction migrateTableAction =
                 new MigrateTableAction(
@@ -57,6 +57,6 @@ public void printHelp() {
                 "  migrate_table --warehouse <warehouse-path> --src-type hive "
                         + "--table <database.table_name> "
                         + "[--catalog-conf <key>=<value] "
-                        + "[--tblproperties <key>=<value>,<key>=<value>,...]");
+                        + "[--options <key>=<value>,<key>=<value>,...]");
     }
 }
diff --git a/...n-spark-common/src/main/java/org/apache/paimon/spark/procedure/MigrateTableProcedure.java b/...n-spark-common/src/main/java/org/apache/paimon/spark/procedure/MigrateTableProcedure.java
@@ -49,7 +49,7 @@ public class MigrateTableProcedure extends BaseProcedure {
             new ProcedureParameter[] {
                 ProcedureParameter.required("src_type", StringType),
                 ProcedureParameter.required("table", StringType),
-                ProcedureParameter.optional("tblproperties", StringType)
+                ProcedureParameter.optional("options", StringType)
             };
 
     private static final StructType OUTPUT_TYPE =

diff --git a/...k-common/src/test/scala/org/apache/paimon/spark/procedure/MigrateTableProcedureTest.scala b/...k-common/src/test/scala/org/apache/paimon/spark/procedure/MigrateTableProcedureTest.scala
@@ -35,7 +35,7 @@ class MigrateTableProcedureTest extends PaimonHiveTestBase {
           spark.sql(s"INSERT INTO hive_tbl VALUES ('1', 'a', 'p1'), ('2', 'b', 'p2')")
 
           spark.sql(
-            s"CALL sys.migrate_table(src_type => 'hive', table => '$hiveDbName.hive_tbl', tblproperties => 'file.format=$format')")
+            s"CALL sys.migrate_table(src_type => 'hive', table => '$hiveDbName.hive_tbl', options => 'file.format=$format')")
 
           checkAnswer(
             spark.sql(s"SELECT * FROM hive_tbl ORDER BY id"),
@@ -58,7 +58,7 @@ class MigrateTableProcedureTest extends PaimonHiveTestBase {
           spark.sql(s"INSERT INTO hive_tbl VALUES ('1', 'a', 'p1'), ('2', 'b', 'p2')")
 
           spark.sql(
-            s"CALL sys.migrate_table(src_type => 'hive', table => '$hiveDbName.hive_tbl', tblproperties => 'file.format=$format')")
+            s"CALL sys.migrate_table(src_type => 'hive', table => '$hiveDbName.hive_tbl', options => 'file.format=$format')")
 
           checkAnswer(
             spark.sql(s"SELECT * FROM hive_tbl ORDER BY id"),