Hi, 各位好:
我在使用state processor api创建新的包含kafka相关state的savepoint用来修改max
parallelism时,创建成功后使用此savepoint来重启任务,发现抛出如下异常:
{code}
java.lang.Exception: Exception while creating StreamOperatorStateContext.
at
org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl.streamOperatorSt
使用flink-parcel部署flink-yarn成功,为了模拟服务器宕机,kill掉其中一个flink-yarn实例,为什么每次kill之后都有另外一个非手动kill的yarn
application标记为finished
application_1612236486024_0009hdfsFlink session clusterApache
Flinkroot.users.hdfs0Tue Feb 2 11:48:10 +0800 2021Tue Feb 2 11:48:11 +0800
2021Tue Feb 2 13:40:39 +0800 2021KILLED
在使用zookeeper 实现ha时,重启3个flink-yarn中一个实例时出现如下问题,请问是什么原因:
org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.KeeperException$NoNodeException:
KeeperErrorCode = NoNode for /flink-ha/cluster_yarn/leader
at
org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.KeeperException.create(Kee
退订