Re: Native K8S HA Session Cluster Issue 1.12.1

2021-02-17 Thread Yang Wang
I second till's suggestion. You could also build your own flink-kubernetes jar from source code of branch 1.12. After that, bundle the flink-kubernetes jar to the image under /opt/flink/lib directory. And push to docker repository. Some users come into the same issues with you and have verified t

Re: Native K8S HA Session Cluster Issue 1.12.1

2021-02-11 Thread Till Rohrmann
Hi Kevin, Unfortunately, the root cause for the error is missing. I can only guess but it could indeed be FLINK-20417 [1]. If this is the case, then the problem should be fixed with the upcoming Flink 1.12.2 version. It should be released next week hopefully. If it should be a different problem, t

Native K8S HA Session Cluster Issue 1.12.1

2021-02-11 Thread Bohinski, Kevin
Hi All, On long lived session clusters we are seeing a k8s error `Error while watching the ConfigMap`. Good news is it looks like `too old resource version` issue is fixed :). Logs are attached below. Any tips? best Kevin 2021-02-11 07:55:15,249 INFO org.apache.flink.runtime.checkpoint.Chec