如题,在工作中经常遇到flink任务各种异常,今天我列了下主要的异常,想请大佬们对不同异常的出现场景根据自身经验说下原因、场景、还有可能的优化解决方案。
(1) org.apache.flink.runtime.jobmaster.JobMasterException: TaskManager with id {...} is no longer reachable. (2) org.apache.flink.util.FlinkException: The TaskExecutor is shutting down. (3) org.apache.flink.runtime.io.network.netty.exception.RemoteTransportException: Lost connection to task manager '10.35.213.153/10.35.213.153:2085'. This indicates that the remote task manager was lost. (4) org.apache.flink.runtime.io.network.netty.exception.LocalTransportException: readAddress(..) failed: Connection timed out (connection to '10.35.116.170/10.35.116.170:2031') (5) org.apache.flink.shaded.netty4.io.netty.channel.unix.Errors$NativeIoException: writeAddress(..) failed: Connection reset by peer (6) java.util.concurrent.TimeoutException: Heartbeat of TaskManager with id {...} timed out.