问题一:我在网上一些案例了解到 flink cdc 不支持源表结构变更同步到目标表,是这样的吗?
我在网上一些案例了解到 flink cdc 不支持源表结构变更同步到目标表,是这样的吗?我这边只是简单的同步mysql,源库一部分表同步到目标库mysql。
参考答案:
不支持。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/599200?spm=a2c6h.12873639.article-detail.62.50e24378TRW91E
问题二:Flink CDC里有没有flink从mysql到clickhouse的相关文档学习呀?
Flink CDC里有没有flink从mysql到clickhouse,还有mysql到mysql相关计算的demo学习一下呢?
参考答案:
关于Flink CDC从MySQL到ClickHouse以及MySQL到MySQL的相关计算Demo,阿里云社区、Apache Flink官方文档或GitHub上的开源项目中可能有实例代码供参考学习。例如,在Flink官方文档中,通常会有不同数据源和接收器的连接器配置示例,而针对特定场景下的实战案例则可能需要通过搜索相关教程或博客文章获取。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/599199?spm=a2c6h.12873639.article-detail.63.50e24378TRW91E
问题三:Flink CDC3.0增量读取source时候,sink可以根据并行度生效,以表单位分发 了吗?
Flink CDC3.0增量读取source时候,sink可以根据并行度生效,以表单位或者其他特性分发到其他taskmanager了吗?是自动根据库表了么,有没有issue或者其他介绍呀?
参考答案:
可以。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/599198?spm=a2c6h.12873639.article-detail.64.50e24378TRW91E
问题四:Flink CDC可以直接升级里面的Debezium版本吗 ?
Flink CDC可以直接升级里面的Debezium版本吗 ?
参考答案:
升级是需要做适配的,尤其大版本升级,接口都不一定兼容。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/599197?spm=a2c6h.12873639.article-detail.65.50e24378TRW91E
问题五:Flink CDC里在使用rocksdb作为状态后端,并且使用全量checkpoint,不会这样吗?
Flink CDC里在使用rocksdb作为状态后端,并且使用全量checkpoint,不会触发FULL_STATE_SCAN_SNAPSHOT清理策略?
参考答案:
全量Checkpoint意味着Flink会保存整个流处理任务的所有状态信息。
在Flink CDC场景下,这意味着不仅包括普通算子的状态,还包括了源连接器(例如从数据库读取变更日志的Debezium等)的内部状态,即已经消费过的数据位置信息。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/599196?spm=a2c6h.12873639.article-detail.66.50e24378TRW91E