Flink有大佬碰到过Caused by: org.apache.flink.shaded.nett

是的,Flink会因为Netty这个底层网络库报"Connection reset by peer"这个错误并触发任务重启。

可能的原因和解决办法:

网络出现了干扰或者拥塞,连接被断掉。需要查看网络状态是否正常。

TaskManager和JobManager节点之间TCP连接长时间Idle后断开。可以增加心跳频率avoid.idle.timeout参数。

客户端与JobManager连接长时间Idle后断开。增加jobmanager.web.idle-timeout配置。

Flink内部Flow控制或流量控制设置过于严格。调整流控参数如分配给每个连接的buffer数量。

Job资源分配上低估了实际需求,造成网络或IO拥塞。重新规划Job资源。

Netty版本不兼容问题。尝试升级或降级Netty版本。

极端情况可能是集群某些组件性能不足。