问题一:flink cdc 能捕获数据源DDL变更吗?捕获后是怎么处理的?
flink cdc 能捕获数据源DDL变更吗?捕获后是怎么处理的?
参考回答:
可以捕捉mysql一类的的,不做处理,自己处理
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/479542?spm=a2c6h.14164896.0.0.42e8d9dfMFjOUr
问题二:flink CDC 当第一次全量正常输出后,源表中数据任何变更就无法再被捕获到了,为什么
flink CDC 同步高可用mysql8.0库中表数据时,当第一次全量正常输出后,源表中数据任何变更就无法再被捕获到了,日志中好像也没什么报错信息,请问大概是什么原因呢?
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/484541?spm=a2c6h.14164896.0.0.60fcd9df1YFUTg
问题三:请问flink sql cdc同步同一个mongo数据源到mysql中数据条目正确,但同步是到doris中数据存在很多重复数据 是啥原因?
请问flink sql cdc同步同一个mongo数据源到mysql中数据条目正确,但同步是到doris中数据存在很多重复数据 是啥原因?
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/479440?spm=a2c6h.14164896.0.0.60fcd9df1YFUTg
问题四:请问flink-cdc数据源是oracle/mysql 目标端是hdfs/doris/mysql.这种长时间增量拉取,能保证数据一致性么
请问flink-cdc数据源是oracle/mysql 目标端是hdfs/doris/mysql.这种长时间增量拉取,能保证数据一致性么
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/470554?spm=a2c6h.14164896.0.0.60fcd9df1YFUTg
问题五:对于Flink CDC,基于分片的读取数据源,并行读取,数据库日志,如果 是有新增、有修改、有删除,随机分布在日志里,这样能切分开,并行执行吗,也只通是按顺序 串行执行吧?
对于Flink CDC,基于分片的读取数据源,并行读取,数据库日志,如果 是有新增、有修改、有删除,随机分布在日志里,这样能切分开,并行执行吗,也只通是按顺序 串行执行吧?
参考回答:
有些 sink,可以并行执行吧,通过 gmt_modified 或者采集时间合并
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/481229?spm=a2c6h.14164896.0.0.1bf2d9dfeERj61