问题一:flink cdc现在有哪个版本可以支持sqlserver的整库同步么?没有主键的表能同步么?
flink cdc现在有哪个版本可以支持sqlserver的整库同步么?没有主键的表能同步么?
参考答案:
mysql的cdc 2.4版本支持无主键表的同步。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/590805
问题二:Flink CDC里使用Reactive 模式下参数无法取消slot吗?
Flink CDC里使用Reactive 模式下的flink服务, 执行cdc任务, scan.incremental.close-idle-reader.enabled=true参数无法取消不再使用的slot吗? 测试默认模式下是可以的.
参考答案:
在 Reactive 模式下,即使启用了关闭空闲读取器的功能,只要 Flink 作业整体上还在运行,那么分配给该作业的 Slot 就可能不会因为个别读取器关闭而自动回收。除非整个作业被终止或者资源管理策略进行了相应的调整。
scan.incremental.close-idle-reader.enabled
参数在 Apache Flink CDC 场景中,主要作用是控制 CDC Source(如 Debezium)是否关闭长时间未接收到数据变更的读取器。当设置为 true
时,如果源端长时间没有新的变更事件产生,该参数可以使得 CDC Source 关闭空闲的读取器以节省资源。
但是,这个参数并不会直接影响到 Flink 的 Slot 管理机制。Slot 是 Flink 中的任务执行单元,由 TaskManager 提供,用于运行并行任务实例。Slot 是否被释放或回收,主要取决于 Flink 作业的整体状态以及 Flink 自身的任务调度策略,而并非 CDC 源连接器的某个具体配置项。
所以,要根据实际 CDC 任务的负载动态调整资源使用,在 Reactive 模式下,除了可以考虑开启关闭空闲读取器功能外,还需要结合 Flink 的动态资源管理特性(如动态扩缩容、自定义资源管理器等)进行优化,并且合理监控和调整作业的并行度。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/590804
问题三:flink-cdc3.0,设置整库同步只变更库名,表名和表结构都不变,需要如何设置?
我用的是flink-cdc3.0,mysql同步到doris,设置整库同步,只变更库名,表名和表结构都不变,需要如何设置?
参考答案:
目前不支持变更库名。参考:
https://github.com/ververica/flink-cdc-connectors/pull/2908
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/590844
问题四:Flink CDC里这么做可以不?
Flink CDC里这么做可以不?flink-cdc3.0,整库同步,我配置的
route:
- source-table: 源库..
sink-table: 目标库..
参考答案:
我记得是不支持的,需要一对一的写,下个版本会增加个mapper配合db。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/590842
问题五:Flink CDC我配置mysql CDC,但任务重启(重新执行)后,它总是全量同步数据,要怎么做?
Flink CDC里我配置mysql CDC,但是任务重启(重新执行)后,它总是全量同步数据,具体有什么参数可以配置使用增量同步啊?
参考答案:
Flink CDC 在进行MySQL的增量同步操作时,基于binlog来监视数据库的变化。当遇到任务重启的情况,Flink CDC作业会从上次停止的地方继续消费数据,而并非重新全量同步。然而,如果你希望跳过Snapshot阶段,只从变更数据开始读取,你可以通过调整Flink CDC的相关参数来实现。这通常可以在Flink的配置文件中完成,具体的配置项可能包括:
scan.startup.mode
: 这个参数可以控制Flink CDC作业在启动时的读取模式,包括'latest'(最新的)和'earliest'(最早的)。设置为'latest'表示从最新的数据开始读取;设置为'earliest'则表示从最早的数据开始读取。scan.startup.timestamp-millis
: 这个参数用来指定Flink CDC作业在启动时的时间戳,以帮助精确定位到需要读取的位置。
请注意,这些配置可能需要根据实际的业务需求和运行环境进行适当的调整。同时,确保你已经正确安装并配置了Flink和MySQL,并且MySQL的binlog功能已经打开。
关于本问题的更多回答可点击进行查看: