问题一:Flink CDC这个是缺少哪个包呀?
Flink CDC这个是缺少哪个包呀?
参考答案:
检查一下你flink集群lib下是不是有cdc其他的版本
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/582166
问题二:flinkcdc 3.0 可以动态添加需要同步的表么?
flinkcdc 3.0 可以动态添加需要同步的表么?
参考答案:
目前不行,设计上后续会支持自动加表,不需要动态加表
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/582162
问题三:Flink CDC获取这种合并算子链的指标吗,都是0要咋处理?有没有其他途径能获取到指标?
Flink CDC获取这种合并算子链的指标吗,都是0要咋处理?有没有其他途径能获取到指标?
参考答案:
拆开算子链
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/582160
问题四:flink cdc 2.4.1 哪个参数可以设置一下让他跟数据库一致啊0.0?
flink cdc 2.4.1 读取pgsql的无时区格式的时间时候,获取到的数据全是utc的,哪个参数可以设置一下让他跟数据库一致啊0.0?
这个flink读取到的,实际上数据库是无时区的
参考答案:
采用toLocalDateTime吧
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/582159
问题五:Flink CDC是不是cdc对于源库数据的抽取 存在有些元数据的改变无法处理 ?
Flink CDC中现在MySQL cdc 抽取经常出现这个问题 是不是cdc对于源库数据的抽取 存在有些元数据的改变无法处理 ?
参考答案:
SCAN_SNAPSHOT_FETCH_SIZE 调小点可以缓解这个问题
关于本问题的更多回答可点击进行查看: