-- 单表同步
bin/flink run
/opt/module/flink/opt/paimon-flink-action-0.9.0.jar
mysql-sync-table
--warehouse hdfs://xx:8020/paimon/hive
--database default
--table user1_sink
--primary-keys id
--mysql-conf hostname=xx
--mysql-conf username=xx
--mysql-conf password=xx
--mysql-conf database-name=source_cdc
--mysql-conf table-name='user1'
--catalog-conf metastore=hive
--catalog-conf uri=thrift://xx:9083
--table-conf bucket=4
--table-conf changelog-producer=input
--table-conf sink.parallelism=4
-- 整库同步，可以过滤表。 表过多，则分成多个表组同步，进行解耦
bin/flink run
/opt/module/flink/opt/paimon-flink-action-0.9.0.jar
mysql-sync-database
--warehouse hdfs://xx:8020/paimon/hive
--database test
--mysql-conf hostname=xx
--mysql-conf username=xx
--mysql-conf password=xx
--mysql-conf database-name=source_cdc
--catalog-conf metastore=hive
--catalog-conf uri=thrift://xx:9083
--table-conf bucket=2
--table-conf changelog-producer=input
--table-conf sink.parallelism=2
--including-tables 'user1|user2'