flink任务经常性报错

HI 读kafka，入hbase和kafka flink任务经常性报错 org.apache.flink.runtime.io.network.netty.exception.RemoteTransportException: Connection unexpectedly closed by remote task manager 'cdh02/xxx:42892'. This might indicate that the remote task manager was lost.

Re: flink任务经常性报错

这个报错的意思是有 TM 断开了连接，我觉得可以首先看看你们 'cdh02/xxx:42892' 这个丢失的 TM 的日志上有没有什么异常信息，如果没有的话也可以看看对应的机器监控有没有异常。 潘明文 于2022年3月7日周一 10:21写道： > HI 读kafka，入hbase和kafka > flink任务经常性报错 > > org.apache.flink.runtime.io.network.netty.exception.RemoteTransportException: > Connection unexpecte

Re:Re: flink任务经常性报错

应的机器监控有没有异常。 > >潘明文 于2022年3月7日周一 10:21写道： > >> HI 读kafka，入hbase和kafka >> flink任务经常性报错 >> >> org.apache.flink.runtime.io.network.netty.exception.RemoteTransportException: >> Connection unexpectedly closed by remote task manager 'cdh02/xxx:42892'. >> This might indicate that the remote task manager was lost.