Hello Flink community , i am getting this exceptio...
# troubleshootinga
Abhilash S.R
03/01/2023, 2:49 AMHello Flink community , i am getting this exception while using the flink operator 1.4 with Zookeeper HA and job goes down . If the HA is disabled then am not seeing the exception and job is running fine . could you please suggest what might be wrong here
Copy code
org.apache.flink.runtime.rpc.exceptions.FencingTokenException: Fencing token mismatch: Ignoring message LocalFencedMessage(af00754d9d0dafaccdb1770d2e3f480e, LocalRpcInvocation(requestResourceOverview(Time))) because the fencing token af00754d9d0dafaccdb1770d2e3f480e did not match the expected fencing token 8b714cf5eb5af40851ea06f1df8d4124.
at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:88)
at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:158)
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26)
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21)k
kingsathurthi
03/01/2023, 8:04 AMShare your flink-conf
kingsathurthi
03/01/2023, 8:04 AMOr else you refer here https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/deployment/ha/zookeeper_ha/
r
RICHARD JOY
03/13/2023, 8:11 PMWhat’s the purpose of a need for zookeeper when operator is used with deployment ? Doesn’t k8 deployment handles it itself?
k
kingsathurthi
03/14/2023, 5:57 AMYou need to have running zookeeper setup and update zookeeper config in flink-config.yaml refer above link reference