- 基于docker镜像:flink:1.11.2-scala_2.11
- 使用环境:基于k8s进行部署
Fatal error occurred in the cluster entrypoint.
io.fabric8.kubernetes.client.KubernetesClientException Exception : too old resource version: 122201792 (122215353)
at io.fabric8.kubernetes.client.dsl.internal.WatchConnectionManager$1.onMessage(WatchConnectionManager.java:259)
at org.apache.flink.kubernetes.shaded.okhttp3.internal.ws.RealWebSocket.onReadMessage(RealWebSocket.java:323)
at org.apache.flink.kubernetes.shaded.okhttp3.internal.ws.WebSocketReader.readMessageframe(WebSocketReader.java:219)
at org.apache.flink.kubernetes.shaded.okhttp3.internal.ws.WebSocketReader.processNextframe(WebSocketReader.java:105)
at org.apache.flink.kubernetes.shaded.okhttp3.internal.ws.RealWebSocket.loopReader(RealWebSocket.java:274)
at org.apache.flink.kubernetes.shaded.okhttp3.internal.ws.RealWebSocket$2.onResponse(RealWebSocket.java:214)
at org.apache.flink.kubernetes.shaded.okhttp3.RealCall$AsyncCall.execute(RealCall.java:206)
at org.apache.flink.kubernetes.shaded.okhttp3.internal.NamedRunnable.run(NamedRunnable.java:32)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Fatal error occurred in ResourceManager. io.fabric8.kubernetes.client.KubernetesClientException Exception : too old resource version: 122201792 (122215353) at io.fabric8.kubernetes.client.dsl.internal.WatchConnectionManager$1.onMessage(WatchConnectionManager.java:259) at org.apache.flink.kubernetes.shaded.okhttp3.internal.ws.RealWebSocket.onReadMessage(RealWebSocket.java:323) at org.apache.flink.kubernetes.shaded.okhttp3.internal.ws.WebSocketReader.readMessageframe(WebSocketReader.java:219) at org.apache.flink.kubernetes.shaded.okhttp3.internal.ws.WebSocketReader.processNextframe(WebSocketReader.java:105) at org.apache.flink.kubernetes.shaded.okhttp3.internal.ws.RealWebSocket.loopReader(RealWebSocket.java:274) at org.apache.flink.kubernetes.shaded.okhttp3.internal.ws.RealWebSocket$2.onResponse(RealWebSocket.java:214) at org.apache.flink.kubernetes.shaded.okhttp3.RealCall$AsyncCall.execute(RealCall.java:206) at org.apache.flink.kubernetes.shaded.okhttp3.internal.NamedRunnable.run(NamedRunnable.java:32) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748)解决方案
这个是flink 1.11的bug,在后续及以上版本flink:1.12.2-scala_2.12-java8已经修复



