问题一:Flink CDC中oracle-cdc全量没有问题,增量也没有问题,但是持续跑一段时间出这个错了?
Flink CDC中oracle-cdc全量没有问题,增量也没有问题,但是持续跑一段时间出这个错了?
参考回答:
这个感觉是有schema 有修改了,作业pattern和完整异常栈可以发下嘛?
关于本问题的更多回答可点击原文查看:
https://developer.aliyun.com/ask/584565
问题二:Flink CDC中报线程池问题 我把source表的调到100 也是数据库限制了吗?
Flink CDC中报线程池问题 我把source表的调到100 也是数据库限制了吗?
参考回答:
得问下你们dba或者看下db侧指标,server-id数量越多对于源db压力越大,应尽可能的减少
关于本问题的更多回答可点击原文查看:
https://developer.aliyun.com/ask/584563
问题三:flink-cdc-3.0 这个问题有啥解决办法么?
flink-cdc-3.0 的 Column类 没有 default value 属性 导致 schema-change-evulotion 下游add column的时候 无法携带默认值,这个问题有啥解决办法么?
参考回答:
mysql alter一个字段,把默认值null换成其他值,doris保持不了一致,没得binlog
关于本问题的更多回答可点击原文查看:
https://developer.aliyun.com/ask/584557
问题四:Flink CDC任务报错,官网找到解决方案,但是这个参数我怎么在SQL里增加?
Flink CDC任务报错,官网找到解决方案,但是这个参数我怎么在SQL里增加?
参考回答:
看着是db2的参数,你看下db2的连接参数,看如何定义
关于本问题的更多回答可点击原文查看:
https://developer.aliyun.com/ask/584554
问题五:flink cdc 读取业务库数据,提示类型转换错误,请问是需要通过debezium*参数解决吗?
flink cdc 读取业务库数据,提示类型转换错误,业务库原类型为decimal,我这边读取是mapping为decimal,或者bytes以及string 都报这同一个错误,请问是需要通过debezium*参数解决吗?
参考回答:
需要改源码
关于本问题的更多回答可点击原文查看: