使用flinkCDC同步oceanbase的两张表，然后进行双流join关联， 报错问题在哪？
使用flinkCDC同步oceanbase的两张表，然后进行双流join关联， 报错：Failed to create oblogreader，但是单表select打印没有问题，OceanBase_cdc是2.4.0的，问题在哪？
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
-
北京阿里云ACE会长
看起来问题是在创建 OceanBase LogProxyReader 时出现了错误。错误信息中提到了 "Failed to create oblogreader" 和 "LogProxy refused handshake request"。
这种错误通常是由于与 OceanBase LogProxy 的连接或握手过程中出现了问题导致的。以下是一些可能的原因和解决方法：
检查连接配置：确保你在 Flink CDC 的配置中正确指定了与 OceanBase LogProxy 的连接相关的配置项，如主机名、端口、用户名和密码等。确保这些配置项与你连接 OceanBase 数据库的凭据和网络设置相匹配。
检查 LogProxy 版本：确保你使用的 OceanBase LogProxy 版本与 Flink CDC 兼容。不同版本的 LogProxy 和 Flink CDC 可能存在兼容性问题。查看 Flink CDC 的文档或官方支持资源，了解支持的 LogProxy 版本和兼容性要求。
检查网络连接和防火墙设置：确保你的网络连接正常，并且没有防火墙或网络策略阻止 Flink CDC 与 OceanBase LogProxy 的通信。尝试使用 telnet 或其他网络工具测试连接到 LogProxy 的端口是否可行。
检查 LogProxy 的日志和错误信息：查看 LogProxy 的日志文件以获取更详细的错误信息。可能会有其他错误或警告提示，可以帮助你定位问题所在。
2023-08-13 17:33:17赞同 展开评论
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。