问题一:Flink CDC里根据官网oracle cdc抄下来,oracle拉数据1条1条的来,为啥这么慢?
Flink CDC里根据官网oracle cdc抄下来,oracle拉数据1条1条的来,为啥这么慢?
参考回答:
你用的是不是Incremental Snapshot based DataStream那个示例,你换成SourceFunction-based DataStream这个试试。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/610003
问题二:Flink CDC里这个为啥报错?
Flink CDC里这个为啥报错?
参考回答:
路径有问题。可能包上传不全。你这两个.. ,在当前dir开启shell 。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/610001
问题三:Flink CDC里第一次抽的时候成功抽取,但后续update和insert都卡死不动了,怎么排查?
Flink CDC里第一次抽的时候成功抽取,但后续update和insert都卡死不动了,怎么排查?
参考回答:
找到问题原因了,是没有加这两个参数debezium.log.mining.continuous.mine,debezium.log.mining.strategy,导致像假死了一样。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/609989
问题四:Flink CDC里oraclecdc这个日志要打印十多分钟才开始同步?
Flink CDC里oraclecdc这个日志要打印十多分钟才开始同步?
参考回答:
debezium.database.history.store.only.captured.tables.ddl=true加上这个参数试试。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/609979
问题五:Flink CDC里这个异常怎么处理?
Flink CDC里这个异常怎么处理?
参考回答:
如果同步的是只读数据库,记得开启集群gtid。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/609966