问答 2023-08-28 来自:开发者社区

Flink CDC为什么我第一次初始化执行了以后,正常来说mysql就4亿条左右数据,现在执行了?

Flink CDC为什么我第一次初始化执行了以后,正常来说mysql就4亿条左右数据,现在执行了5亿多条还没有执行完,是会重复执行吗? 怎么看执行到哪张表了或者哪些已经同步完了呀?

问答 2023-08-28 来自:开发者社区

请问Flink CDC这个mysql-cdc输出的op列(黄框,代表数据的增删改)能否捕获使用?

问题1:请问Flink CDC这个mysql-cdc输出的op列(黄框,代表数据的增删改)能否捕获使用(比如写入临时表进行使用)?现在这样写能够print出op列,但不能写入数据库?问题2:加上这个op_ts列吗?这个似乎是本地时间戳,不是 +U,+I,-U这一类型呀。能否指教更多一点?

问答 2023-08-28 来自:开发者社区

请问Flink CDC这个mysql-cdc输出的op列(黄框,代表数据的增删改)能否写入临时表?

请问Flink CDC这个mysql-cdc输出的op列(黄框,代表数据的增删改)能否写入临时表进行使用?现在这样能够print,但不能写入数据库?

问答 2023-08-23 来自:开发者社区

请教下各位大佬,flink cdc同时采集mysql多个表的数据到kafka,是都写到同一个?

请教下各位大佬,flink cdc同时采集mysql多个表的数据到kafka,是都写到同一个topic吗?怎么实现每张表写到对应的topic呢?

问答 2023-08-23 来自:开发者社区

Flink CDC sql-client内同步mysql表没有数据是什么情况 lib内集成了?

Flink CDC sql-client内同步mysql表没有数据是什么情况lib内集成了sql-connector-mysql包?binlog是开的,SET 'execution.checkpointing.interval' = '3s';这个嘛?

问答 2023-08-23 来自:开发者社区

各位大佬好,Flink CDC 中我正尝试捕获mysql数据变更并写入到Oracle数据库,开始用?

各位大佬好,Flink CDC 中我正尝试捕获mysql数据变更并写入到Oracle数据库,开始用的是oracle-cdc connector,调用flink sql时候报错: Connector 'oracle-cdc' can only be used as a source. It cannot be used as a sink.然后换了jdbc connector,报错:Cannot ....

问答 2023-08-22 来自:开发者社区

各位老师,咨询下,flink cdc 消费mysql,不消费数据,日志不断的打印这个,请问是什么?

各位老师,咨询下,flink cdc 消费mysql,不消费数据,日志不断的打印这个,请问是什么原因呢、谢谢

问答 2023-08-22 来自:开发者社区

大佬们 Flink CDC读取mysql的数据遇到0000-00-00 00:00:00这是时?

大佬们 Flink CDC读取mysql的数据遇到0000-00-00 00:00:00这是时间数据怎么处理的呀?

问答 2023-08-22 来自:开发者社区

请教下Flink CDC mysql cdc读取mysql的数据 中文乱码了是为什么呢?本地是正常

请教下Flink CDC mysql cdc读取mysql的数据 中文乱码了是为什么呢?本地是正常的,服务器上乱码了

问答 2023-08-22 来自:开发者社区

Flink CDC增量监听Mysql的数据,如何停机更新的话,那这停机更新这部分新增的数据要怎么?

Flink CDC增量监听Mysql的数据,如何停机更新的话,那这停机更新这部分新增的数据要怎么处理?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。