退订

退订

flink-yarn ha

在使用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

flink-parcel使用求助

使用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

TaggedOperatorSubtaskState is missing when creating a new savepoint using state processor api

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