diff --git a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseActionFactory.java b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseActionFactory.java index 4c0a14854d8d..eb3332c731fd 100644 --- a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseActionFactory.java +++ b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncDatabaseActionFactory.java @@ -54,14 +54,16 @@ public void printHelp() { System.out.println("Syntax:"); System.out.println( - " kafka_sync_database --warehouse --database " - + "[--table_prefix ] " - + "[--table_suffix ] " - + "[--including_tables ] " - + "[--excluding_tables ] " - + "[--type_mapping ] " - + "[--kafka_conf [--kafka_conf ...]] " - + "[--catalog_conf [--catalog_conf ...]] " + " kafka_sync_database \\\n" + + "--warehouse \\\n" + + "--database \\\n" + + "[--table_prefix ] \\\n" + + "[--table_suffix ] \\\n" + + "[--including_tables ] \\\n" + + "[--excluding_tables ] \\\n" + + "[--type_mapping ] \\\n" + + "[--kafka_conf [--kafka_conf ...]] \\\n" + + "[--catalog_conf [--catalog_conf ...]] \\\n" + "[--table_conf [--table_conf ...]]"); System.out.println(); diff --git a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableActionFactory.java b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableActionFactory.java index 530e4af7c368..59976c9abbd0 100644 --- a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableActionFactory.java +++ b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/kafka/KafkaSyncTableActionFactory.java @@ -52,14 +52,16 @@ public void printHelp() { System.out.println("Syntax:"); System.out.println( - " kafka_sync_table --warehouse --database " - + "--table " - + "[--partition_keys ] " - + "[--primary_keys ] " - + "[--type_mapping ] " - + "[--computed_column <'column_name=expr_name(args[, ...])'> [--computed_column ...]] " - + "[--kafka_conf [--kafka_conf ...]] " - + "[--catalog_conf [--catalog_conf ...]] " + " kafka_sync_table \\\n" + + "--warehouse \\\n" + + "--database \\\n" + + "--table \\\n" + + "[--partition_keys ] \\\n" + + "[--primary_keys ] \\\n" + + "[--type_mapping ] \\\n" + + "[--computed_column <'column_name=expr_name(args[, ...])'> [--computed_column ...]] \\\n" + + "[--kafka_conf [--kafka_conf ...]] \\\n" + + "[--catalog_conf [--catalog_conf ...]] \\\n" + "[--table_conf [--table_conf ...]]"); System.out.println(); diff --git a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/MongoDBSyncDatabaseActionFactory.java b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/MongoDBSyncDatabaseActionFactory.java index 6262720de369..3811fd31ee0f 100644 --- a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/MongoDBSyncDatabaseActionFactory.java +++ b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/MongoDBSyncDatabaseActionFactory.java @@ -55,13 +55,15 @@ public void printHelp() { System.out.println("Syntax:"); System.out.println( - " mongodb_sync_database --warehouse --database " - + "[--table_prefix ] " - + "[--table_suffix ] " - + "[--including_tables ] " - + "[--excluding_tables ] " - + "[--mongodb_conf [--mongodb_conf ...]] " - + "[--catalog_conf [--catalog_conf ...]] " + " mongodb_sync_database \\\n" + + "--warehouse \\\n" + + "--database \\\n" + + "[--table_prefix ] \\\n" + + "[--table_suffix ] \\\n" + + "[--including_tables ] \\\n" + + "[--excluding_tables ] \\\n" + + "[--mongodb_conf [--mongodb_conf ...]] \\\n" + + "[--catalog_conf [--catalog_conf ...]] \\\n" + "[--table_conf [--table_conf ...]]"); System.out.println(); diff --git a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/MongoDBSyncTableActionFactory.java b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/MongoDBSyncTableActionFactory.java index 38170d6c66a4..8c7d4c38d25d 100644 --- a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/MongoDBSyncTableActionFactory.java +++ b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mongodb/MongoDBSyncTableActionFactory.java @@ -70,12 +70,14 @@ public void printHelp() { System.out.println("Syntax:"); System.out.println( - " mongodb_sync_table --warehouse --database " - + "--table " - + "[--partition_keys ] " - + "[--computed_column <'column_name=expr_name(args[, ...])'> [--computed_column ...]] " - + "[--mongodb_conf [--mongodb_conf ...]] " - + "[--catalog_conf [--catalog_conf ...]] " + " mongodb_sync_table \\\n" + + "--warehouse \\\n" + + "--database \\\n" + + "--table \\\n" + + "[--partition_keys ] \\\n" + + "[--computed_column <'column_name=expr_name(args[, ...])'> [--computed_column ...]] \\\n" + + "[--mongodb_conf [--mongodb_conf ...]] \\\n" + + "[--catalog_conf [--catalog_conf ...]] \\\n" + "[--table_conf [--table_conf ...]]"); System.out.println(); diff --git a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseActionFactory.java b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseActionFactory.java index 74d0b6f23441..93e25b004c1e 100644 --- a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseActionFactory.java +++ b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseActionFactory.java @@ -76,18 +76,20 @@ public void printHelp() { System.out.println("Syntax:"); System.out.println( - " mysql_sync_database --warehouse --database " - + "[--ignore_incompatible ] " - + "[--merge_shards ] " - + "[--table_prefix ] " - + "[--table_suffix ] " - + "[--including_tables ] " - + "[--excluding_tables ] " - + "[--mode ] " - + "[--metadata_column ] " - + "[--type_mapping ] " - + "[--mysql_conf [--mysql_conf ...]] " - + "[--catalog_conf [--catalog_conf ...]] " + " mysql_sync_database \\\n" + + "--warehouse \\\n" + + "--database \\\n" + + "[--ignore_incompatible ] \\\n" + + "[--merge_shards ] \\\n" + + "[--table_prefix ] \\\n" + + "[--table_suffix ] \\\n" + + "[--including_tables ] \\\n" + + "[--excluding_tables ] \\\n" + + "[--mode ] \\\n" + + "[--metadata_column ] \\\n" + + "[--type_mapping ] \\\n" + + "[--mysql_conf [--mysql_conf ...]] \\\n" + + "[--catalog_conf [--catalog_conf ...]] \\\n" + "[--table_conf [--table_conf ...]]"); System.out.println(); diff --git a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableActionFactory.java b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableActionFactory.java index f4bb73861754..e71f3f48a6b0 100644 --- a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableActionFactory.java +++ b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncTableActionFactory.java @@ -51,15 +51,17 @@ public void printHelp() { System.out.println("Syntax:"); System.out.println( - " mysql_sync_table --warehouse --database " - + "--table " - + "[--partition_keys ] " - + "[--primary_keys ] " - + "[--type_mapping ] " - + "[--computed_column <'column_name=expr_name(args[, ...])'> [--computed_column ...]] " - + "[--metadata_column ] " - + "[--mysql_conf [--mysql_conf ...]] " - + "[--catalog_conf [--catalog_conf ...]] " + " mysql_sync_table \\\n" + + "--warehouse \\\n" + + "--database \\\n" + + "--table \\\n" + + "[--partition_keys ] \\\n" + + "[--primary_keys ] \\\n" + + "[--type_mapping ] \\\n" + + "[--computed_column <'column_name=expr_name(args[, ...])'> [--computed_column ...]] \\\n" + + "[--metadata_column ] \\\n" + + "[--mysql_conf [--mysql_conf ...]] \\\n" + + "[--catalog_conf [--catalog_conf ...]] \\\n" + "[--table_conf [--table_conf ...]]"); System.out.println(); diff --git a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/postgres/PostgresSyncTableActionFactory.java b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/postgres/PostgresSyncTableActionFactory.java index a68f6366e5d2..d573be02b42c 100644 --- a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/postgres/PostgresSyncTableActionFactory.java +++ b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/postgres/PostgresSyncTableActionFactory.java @@ -52,16 +52,17 @@ public void printHelp() { System.out.println("Syntax:"); System.out.println( - " postgres_sync_table --warehouse --database " - + "--table " - + "--table " - + "[--partition_keys ] " - + "[--primary_keys ] " - + "[--type_mapping ] " - + "[--computed_column <'column_name=expr_name(args[, ...])'> [--computed_column ...]] " - + "[--metadata_column ] " - + "[--postgres_conf [--postgres_conf ...]] " - + "[--catalog_conf [--catalog_conf ...]] " + " postgres_sync_table \\\n" + + "--warehouse \\\n" + + "--database \\\n" + + "--table \\\n" + + "[--partition_keys ] \\\n" + + "[--primary_keys ] \\\n" + + "[--type_mapping ] \\\n" + + "[--computed_column <'column_name=expr_name(args[, ...])'> [--computed_column ...]] \\\n" + + "[--metadata_column ] \\\n" + + "[--postgres_conf [--postgres_conf ...]] \\\n" + + "[--catalog_conf [--catalog_conf ...]] \\\n" + "[--table_conf [--table_conf ...]]"); System.out.println(); diff --git a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/pulsar/PulsarSyncDatabaseActionFactory.java b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/pulsar/PulsarSyncDatabaseActionFactory.java index 26af229c5713..7008a577d9db 100644 --- a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/pulsar/PulsarSyncDatabaseActionFactory.java +++ b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/pulsar/PulsarSyncDatabaseActionFactory.java @@ -54,14 +54,16 @@ public void printHelp() { System.out.println("Syntax:"); System.out.println( - " pulsar_sync_database --warehouse --database " - + "[--table_prefix ] " - + "[--table_suffix ] " - + "[--including_tables ] " - + "[--excluding_tables ] " - + "[--type_mapping ] " - + "[--pulsar_conf [--pulsar_conf ...]] " - + "[--catalog_conf [--catalog_conf ...]] " + " pulsar_sync_database \\\n" + + "--warehouse \\\n" + + "--database \\\n" + + "[--table_prefix ] \\\n" + + "[--table_suffix ] \\\n" + + "[--including_tables ] \\\n" + + "[--excluding_tables ] \\\n" + + "[--type_mapping ] \\\n" + + "[--pulsar_conf [--pulsar_conf ...]] \\\n" + + "[--catalog_conf [--catalog_conf ...]] \\\n" + "[--table_conf [--table_conf ...]]"); System.out.println(); diff --git a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/pulsar/PulsarSyncTableActionFactory.java b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/pulsar/PulsarSyncTableActionFactory.java index 25822a7b87a1..db0c97bff540 100644 --- a/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/pulsar/PulsarSyncTableActionFactory.java +++ b/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/pulsar/PulsarSyncTableActionFactory.java @@ -51,14 +51,16 @@ public void printHelp() { System.out.println("Syntax:"); System.out.println( - " pulsar_sync_table --warehouse --database " - + "--table " - + "[--partition_keys ] " - + "[--primary_keys ] " - + "[--type_mapping ] " - + "[--computed_column <'column_name=expr_name(args[, ...])'> [--computed_column ...]] " - + "[--pulsar_conf [--pulsar_conf ...]] " - + "[--catalog_conf [--catalog_conf ...]] " + " pulsar_sync_table \\\n" + + "--warehouse \\\n" + + "--database \\\n" + + "--table \\\n" + + "[--partition_keys ] \\\n" + + "[--primary_keys ] \\\n" + + "[--type_mapping ] \\\n" + + "[--computed_column <'column_name=expr_name(args[, ...])'> [--computed_column ...]] \\\n" + + "[--pulsar_conf [--pulsar_conf ...]] \\\n" + + "[--catalog_conf [--catalog_conf ...]] \\\n" + "[--table_conf [--table_conf ...]]"); System.out.println();