Rocksdb作为状态后端启动时报错

2019-05-09 文章 zhang yue
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

Re: 请教集群稳定性问题

2019-05-09 文章 Yun Gao
心跳超时的话,先看一下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

请教集群稳定性问题

2019-05-09 文章 naisili Yuan
我的集群配置的是内存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??????????????

2019-05-09 文章 ??????????
flink??