开发者社区 问答 正文

使用paimon-flink-action同步mysql表到paimon问题

版本
flink1.18
paimon1.2
cdc3.2

mysql_sync_table
--warehouse
--database

--table
--primary_keys id
--mysql_conf hostname=

--mysql_conf port=
--mysql_conf username=

--mysql_conf password=
--mysql_conf database-name=

--mysql_conf table-name='cdctest([0-9]+)?'
--table_conf changelog-producer=input
--table_conf bucket=-1
当启动这个任务时,确实识别了cdctest开头的表并同步,但是在不重启任务的情况下,在mysql下新增cdctest开头的表,为什么不会自动识别该表进行同步呀

展开
收起
oa3jrmgwotcw6 2025-12-18 17:56:43 16 分享 版权
0 条回答
写回答
取消 提交回答
问答分类:
问答地址: