问题一:flinkcdc 3.0.1第一次启动 全库同步了,然后 增删改的mysql数据没有及时同步怎么办?
flinkcdc 3.0.1第一次启动 全库同步了, 然后 增删改的mysql数据没有及时同步,这个大致是哪方面的问题?启动的时候整库会同步一次,然后修改数据就不起作用了,大约会停多久?
参考答案:
在消费binlog,可能binlog太多了。可以观察一下flink的metric指标 currentFetchEventTimeLag 如果是0就还在全量阶段。checkpooint没打开。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/609990
问题二:Flink cdc支持TIDB吗?
Flink cdc支持TIDB吗?
参考答案:
支持
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/609984
问题三:Flink CDC里请问flink1.7如何设置持久化checkpoint到阿里云oss啊?
Flink CDC里请问flink1.7如何设置持久化checkpoint到阿里云oss啊?文档中的是savepoint checkpoint也是一致的是吗?
参考答案:
参考:
https://blog.51cto.com/u_16099343/10086264
。不一致,不要放在一个文件夹下,两个dir
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/609982
问题四:Flink CDC里如果整库同步到doris的话,有些表需要建成分区表吗?
Flink CDC里如果整库同步到doris的话,有些表需要建成分区表,有的可能要类似定制化的在doris重新设计表分布,这种还能用整库同步吗,还是必须得单独起一个cdc任务?整库同步任务起了以后,再新建表,好像不会同步到doris了?
参考答案:
目前是,未来会自动同步。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/609980
问题五:Flink CDC里有没有碰到读取pgcdc数据,numeric和decimal类型字段的值乱码?
Flink CDC里有没有碰到读取pgcdc数据,numeric和decimal类型字段的值乱码的问题啊?
参考答案:
流上解析数据传。重新定义那个解析类。
关于本问题的更多回答可点击进行查看: