问题一:Flink CDC里目前遇到了一个连接问题想请教下怎么办?
Flink CDC里目前遇到了一个连接问题想请教下:flink-cdc1.17版本连接pgsql,会有部分任务断连,修改插槽名可以解决。但是查看pg日志提示插槽重复,重试时,插槽名会以_1、_2这边新建插槽。这时flink任务报错日志Database connection failed when starting copy。我看停止的任务,数据库插槽还是存在的。任务连接断开后,我查看pg库中的插槽信息active是关闭状态,这种情况应该怎么继续往下排查?
参考答案:
增量阶段多并发是会创建_1、_2的,重复估计是因为多个Source读一个slot。因为一个slot只能建议一个atcive连接, 所以全量阶段会创建_1, _2后缀的临时slot, 使用完就是移除的。可以试一试3.0版本。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/607289
问题二:Flink CDC里我cdc2.3升级3.0,flink最低版本要求是多少?
Flink CDC里我cdc2.3升级3.0,flink最低版本要求是多少?我现在就是2.3+1.16>3.0+1.8,我从1.6升级到1.8遇到了很严重的版本兼容问题。 。
参考答案:
最好和官方的flink版本一致。官方3.+是flink1.18。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/607267
问题三:Flink CDC里有没有大佬知道这块逻辑现在还适用吗?
Flink CDC里有没有大佬知道这块逻辑现在还适用吗?
参考答案:
适用的。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/607264
问题四:Flink CDC里api的业务流程是怎么样的?
Flink CDC里api的业务流程是怎么样的?
参考答案:
官网有样例。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/607262
问题五:Flink CDC里请问现在新版本,还有stream api的接口文档吗?
Flink CDC里请问现在新版本,还有stream api的接口文档吗?stream api的使用,官方文档会加上去吗?我看现在的都没有。
参考答案:
有的,会一直支持的,source是复用的。
关于本问题的更多回答可点击进行查看: