Hi 看起来像是网络问题导致flink作业source节点连接kafka失败，可以检查一下kafka集群的网络或者flink作业source节点的网络是否有问题
Best, Shammon FY On Fri, May 5, 2023 at 9:41 AM Leonard Xu <xbjt...@gmail.com> wrote: > 可以发送任意内容的邮件到 user-zh-unsubscr...@flink.apache.org 取消订阅来自 > user-zh@flink.apache.org 邮件列表的邮件，邮件列表的订阅管理，可以参考[1] > > 祝好， > Leonard > [1] > https://flink.apache.org/zh/community/#%e9%82%ae%e4%bb%b6%e5%88%97%e8%a1%a8 > > > 2023年5月4日 下午9:00，wuzhongxiu <go574...@163.com> 写道： > > > > 退订 > > > > > > > > | | > > go574...@163.com > > | > > | > > 邮箱：go574...@163.com > > | > > > > > > > > > > ---- 回复的原邮件 ---- > > | 发件人 | zhan...@eastcom-sw.com | > > | 日期 | 2023年05月04日 14:54 | > > | 收件人 | user-zh<user-zh@flink.apache.org> | > > | 抄送至 | | > > | 主题 | checkpoint Kafka Offset commit failed | > > hi，请问在flink(1.14、1.16) checkpoint（10s）提交 kafka偏移量提示 The coordinator is > not available > > > > 查看kafka集群日志都是正常的，手动也可以正确提交偏移量，重启flink > job后也可以正常提交，运行一段时间后又会失败，请问有参数可以优化一下吗？ > > > > flink 日志如下： > > 2023-05-04 11:31:02,636 WARN > org.apache.flink.connector.kafka.source.reader.KafkaSourceReader [] - > Failed to commit consumer offsets for checkpoint 69153 > > org.apache.kafka.clients.consumer.RetriableCommitFailedException: Offset > commit failed with a retriable exception. You should retry committing the > latest consumed offsets. > > Caused by: > org.apache.kafka.common.errors.CoordinatorNotAvailableException: The > coordinator is not available. > >
