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.
这个报错的意思是有 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
应的机器监控有没有异常。
>
>潘明文 于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.