开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

Flink CDC有遇到logproxy:连接关闭,重试成功,一会又关闭,也没有具体的信息?

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

展开
收起
真的很搞笑 2023-09-06 14:35:33 131 0
1 条回答
写回答
取消 提交回答
  • 这个错误通常是由于Flink CDC与LogProxy之间的连接问题引起的。"远程主机强迫关闭了一个现有的连接"通常表示连接在传输过程中被意外关闭。

    可能的原因和解决方法如下:

    网络问题:检查网络连接是否稳定,确保Flink CDC和LogProxy之间的网络连接没有异常。您可以尝试使用其他工具或方法测试网络连接,以确定是否存在网络问题。

    连接超时设置:如果连接超时时间设置太短,可能导致连接被关闭。您可以尝试增加连接超时时间,以允许更长时间的连接。

    资源限制:检查系统资源是否足够支持Flink CDC和LogProxy的正常运行。确保主机上的资源(如内存、CPU等)足够满足连接的需求。

    版本兼容性:确保Flink CDC和LogProxy的版本兼容。有时,不兼容的版本可能导致连接问题。请查阅Flink CDC和LogProxy的文档,了解它们之间的兼容性要求。

    如果以上解决方法无法解决问题,建议您查阅Flink CDC和LogProxy的官方文档,寻求更详细的故障排

    2023-09-25 11:16:33
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载