Ocean Base Flink CDC问题咨询

【测试环境 】
【 OB or 其他组件 】
【 4.2本 】
【问题描述】
想问下这几个问题还都存在吗
【附件及日志】

前两个问题目前的 release 版本依然存在,fix 版本预期会在 3.1 带出,时间大概在本月底,在此之前可以先用这个开发分支 https://github.com/whhe/flink-cdc-connectors/tree/oceanbase

第三个问题应该是之前的代码bug导致的,现在已经不存在了。

1 个赞

这个对应的开发分支 编译完之后应该怎么用呀,怎么调整并行度,pom里显示的版本是2.4-SNAPSHOT这个正常吗

有大佬能看下吗

版本是正常的,使用看这个 https://github.com/whhe/flink-cdc-connectors/blob/oceanbase/docs/content/connectors/oceanbase-cdc(ZH).md

老师,oblogproxy现在联不通了。用开源的那个demo也读不到新增的数据了。这个应该从哪排查呀

要看 oblogproxy 的日志,参考 https://github.com/oceanbase/oblogproxy/wiki/FAQ_ZH

hi 老师,照着文档加了以下参数:
scan.snapshot.chunk.enabled
scan.snapshot.chunk.key-column
但是并行度还是1 这个是哪里不对吗

是 table 模式用的吗,确认下有没有移除旧的 jar 包后重启集群,正常情况下启动并发读之后日志里会打印很多 Execute query chunk data sql 这样的信息的,看下日志里有没有。

流模式可用吗

还有另外一个问题,监听的ob数据在一段时间内没有新增的情况下flink 任务会重启,这个应该怎么解决

Execute query chunk data sql. 没有观察到这个日志

流模式也是可以用的,另外有一点,这个分支增加了 DebeziumDeserializationSchema 的支持,文档里没有写。

重启应该是有异常出现,如果是另一个帖子里的并发异常的话,用修复的包之后应该就好了。

好的,我先试下这个,另外 关于timeout这个 设定就是超时了失败么