flink 版本1.7.2
org.apache.flink.client.program.ProgramInvocationException: Job failed. (JobID:
447c14f1bd0382214a420122215f6792)
at
org.apache.flink.client.program.rest.RestClusterClient.submitJob(RestClusterClient.java:268)
at
org.apache.flink.client.program.ClusterClient.run(C
心跳超时的话,先看一下AM和TM的内存使用情况,看下GC Log有没有长时间的GC。
--
From:naisili Yuan
Send Time:2019 May 10 (Fri.) 09:34
To:user-zh
Subject:请教集群稳定性问题
我的集群配置的是内存checkpoint,自动重启,但是经常跑了一晚上就自动重启,重启的原因日志是这样的:
org.apache.flink.util.FlinkException: The assig
我的集群配置的是内存checkpoint,自动重启,但是经常跑了一晚上就自动重启,重启的原因日志是这样的:
org.apache.flink.util.FlinkException: The assigned slot
f6b9b4065386152879a01dfc7d396f42_1 was removed.
at
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager.removeSlot(SlotManager.java:893)
at
org.apache.flink.r
flink??