FlinkCDC在同步Oracle数据到Doris时，Oracle产生大量归档日志，CDC除了读取归档日志，还会写入吗？
另外在测试变更单条数据，同步延时很大
flink run -Dexecution.checkpointing.interval=5m -Dexecution.checkpointing.timeout=10m -Dparallelism.default=4 -Dexecution.checkpointing.tolerable-failed-checkpoints=100 -c org.apache.doris.flink.tools.cdc.CdcTools /opt/installs/flink-1.17.1/lib/flink-doris-connector-1.17-1.6.2.jar oracle-sync-database --database XXX --oracle-conf hostname=XXX.XXX.XXX.XXX --oracle-conf port=1521 --oracle-conf username=XX --oracle-conf password="" --oracle-conf database-name=XXX --oracle-conf schema-name=XXX --including-tables "A|B" --sink-conf fenodes=XXX:8030 --sink-conf username=XX --sink-conf password= --sink-conf jdbc-url=jdbc:mysql://XXX:9030 --sink-conf sink.label-prefix=label --table-conf replication_num=1
Oracle产生大量归档日志
Viewed 54
1 Answers
添加如下 debezium 的配置项。 'log.mining.strategy' = 'online_catalog','log.mining.continuous.mine' = 'true'
参考文档： https://github.com/apache/flink-cdc/wiki/FAQ(ZH)
