Flink CDC有遇到logproxy:连接关闭,重试成功,一会又关闭,一直循环,也没有具体的信息? java.io.IOException: 远程主机强迫关闭了一个现有的连接, Connection reset by peer
at sun.nio.ch.SocketDispatcher.read0(Native Method)
at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:43)
at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223)
at sun.nio.ch.IOUtil.read(IOUtil.java:192)
at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:380)
at io.netty.buffer.PooledByteBuf.setBytes(PooledByteBuf.java:253)
at io.netty.buffer.AbstractByteBuf.writeBytes(AbstractByteBuf.java:1132)
at io.netty.channel.socket.nio.NioSocketChannel.doReadBytes(NioSocketChannel.java:350)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:151)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:719)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:655)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:581)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:493)
at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
at java.lang.Thread.run(Thread.java:748)
2023-08-28 11:00:39 INFO com.oceanbase.clogproxy.client.connection.ClientHandler - Channel closed with ClientId: 172.17.176.1_67644_1693191585_1_loongair_ob_cx, LogProxy: xxx.xxx.xxx.xxx:2983
2023-08-28 11:00:41 INFO com.oceanbase.clogproxy.client.connection.ClientStream - Try to reconnect
2023-08-28 11:00:41 INFO com.oceanbase.clogproxy.client.connection.ClientStream - Reconnect successfully
这个错误通常是由于Flink CDC与LogProxy之间的连接问题引起的。"远程主机强迫关闭了一个现有的连接"通常表示连接在传输过程中被意外关闭。
可能的原因和解决方法如下:
网络问题:检查网络连接是否稳定,确保Flink CDC和LogProxy之间的网络连接没有异常。您可以尝试使用其他工具或方法测试网络连接,以确定是否存在网络问题。
连接超时设置:如果连接超时时间设置太短,可能导致连接被关闭。您可以尝试增加连接超时时间,以允许更长时间的连接。
资源限制:检查系统资源是否足够支持Flink CDC和LogProxy的正常运行。确保主机上的资源(如内存、CPU等)足够满足连接的需求。
版本兼容性:确保Flink CDC和LogProxy的版本兼容。有时,不兼容的版本可能导致连接问题。请查阅Flink CDC和LogProxy的文档,了解它们之间的兼容性要求。
如果以上解决方法无法解决问题,建议您查阅Flink CDC和LogProxy的官方文档,寻求更详细的故障排
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。