OceanBase数据库中oblogproxy需要给2882端口开墙吗?从flink cdc端提交job后,oblogproxy端没有明显报错,但获取不到变动信息,请问是咋回事呢?
在使用 OceanBase CDC 和 Flink CDC 进行数据变更捕获时,确实需要确保 oblogproxy 的 2882 端口可以与 Flink 任务所在的机器进行通信。因此,您需要确保该端口在防火墙或网络配置中是开放的。
如果您的 oblogproxy 没有明显报错,但 Flink 任务无法获取到变动信息,可能会有以下原因:
oblogproxy 配置问题:请确保您正确配置了 oblogproxy 的相关参数,包括与 Flink CDC 相关的配置(如 binlog_position、binlog_file、oblog_server等)。检查这些配置是否与您的 OceanBase 数据库和 Flink 任务的配置一致。
CDC 触发器配置问题:在 OceanBase 中,CDC 是通过触发器实现的。确保您已正确启用了 CDC,并将触发器绑定到相关的表上。
CDC 数据源问题:检查数据库中是否有活动的写入操作,以及 oblogproxy 是否正确连接到 CDC 数据源。如果没有新的数据写入或变更,Flink CDC 将无法获取到变动信息。
Flink 任务配置问题:确保您在 Flink 任务中正确配置了与 oblogproxy 相关的连接信息,包括 oblogproxy 的地址和端口。同时,检查 Flink 任务的日志,查找是否有任何异常信息。
如果你的OceanBase数据库和flink cdc节点不在同一个网络中,那么需要将2882端口开放在防火墙上,以便oblogproxy能够与flink cdc节点通信。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。