问答 2024-07-10 来自:开发者社区

flinkcdc 采集mysql出现卡在某个binlog文件出不来怎么办?

flinkcdc 采集mysql出现卡在某个binlog文件出不来。 一直重复消费一个文件,看日志是先断开,在重建链接,然后消费binlog,最后Stopped reading binlog after 0 events, no new offset was recorded 。如此往复。 期间数据采集一直是重复的?

问答 2024-06-26 来自:开发者社区

flinkcdc在监听binlog时如果程序停掉,中途又新增,如何让程序在停掉的点重新监听?

flinkcdc在监听binlog时如果程序停掉,中途又新增,如何让程序在停掉的点重新监听?

问答 2024-06-24 来自:开发者社区

flinkcdc在监听binlog的时候如果程序停掉了,如何能让程序在停掉的那个点重新监听呢?

flinkcdc在监听binlog的时候如果程序停掉了,中途binlog又有新增,如何能让程序在停掉的那个点重新监听呢?

问答 2024-05-29 来自:开发者社区

flinkcdc mysql 在同步binlog时是同步一份还是多份给 flink?

flinkcdc中mysql 分库不分表的场景,需要同步多个表,flink sql 中会针对多个表有多个source ,那 mysql 在同步binlog时是同步一份还是多份给 flink? 担心原实例binlog同步给多个伪装的slaver,会影响性能...

问答 2024-05-28 来自:开发者社区

flinkcdc阿里云里面读mysql binlog 单表数据5000条延迟一个小时这个是什么原因?

flinkcdc阿里云里面读mysql binlog 单表数据5000条延迟一个小时 这个是什么原因?

问答 2024-05-16 来自:开发者社区

flinkcdc模式去读holo表的binlog的时候报错,怎么解决?

flinkcdc模式去读holo表的binlog的时候报错,怎么解决?Realtime ingestion service (holohub) not enabled or its endpoint invalid. org.apache.flink.table.api.ValidationException: SQL validation failed. Realtime ingestion.....

问答 2024-03-11 来自:开发者社区

flinkcdc为什么从savepoint启动后发现新加的表是从最新的binlog开始同步数据的?

做flink cdc2doris的操作时,新建一个任务,设置从最早的 binlog 开始同步(scan.startup.mode=earliest-offset)没有问题,然后新加一张表,从savepoint启动后发现新加的表是从最新的binlog开始同步数据的。是正常现象么?

问答 2024-02-06 来自:开发者社区

相同记录的binlog,为什么用FlinkCDC解析出来的位点和用Canal解析出来的差几百个数值?

相同记录的binlog,用FlinkCDC解析出来的位点和用Canal解析出来的差几百个数值,这是什么原因?

问答 2024-01-24 来自:开发者社区

flinkcdc全量+增量读mysql时怎么设置参数可以让消息中包含binlog的offset啊?

flinkcdc全量+增量读mysql时怎么设置参数可以让消息中包含binlog的offset,我看获取到的消息里面只有ts_ms,精确到s的(想通过对比两个任务的binlog的offset进行任务合并)

问答 2024-01-01 来自:开发者社区

FlinkCDC的问题,有没有办法 把这些清理的binlog重新拉回来重新消费?

FlinkCDC的问题,我使用cdc2.4进行Mysql同步,当rds的binlog文件被清理,binlog文件被转存至oss后,有没有办法 把这些清理的binlog重新拉回来重新消费?

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