David Ballano created FLINK-38116:
-------------------------------------
Summary: Flink kubernetes operator RequestWatchProgress Error
Key: FLINK-38116
URL: https://issues.apache.org/jira/browse/FLINK-38116
Project: Flink
Issue Type: Bug
Components: Kubernetes Operator
Affects Versions: 1.12.0
Reporter: David Ballano
Hi guys,
Our Kubernetes cluster has been upgraded to version 1.32, and since then we've
been encountering the following error in the job-manager:
{code:java}
{"instant":{"epochSecond":1752771773,"nanoOfSecond":610256000},"thread":"OkHttp
https://100.64.0.1/...","level":"ERROR","loggerName":"org.apache.flink.kubernetes.shaded.io.fabric8.kubernetes.client.dsl.internal.AbstractWatchManager","message":"Error
received: Status(apiVersion=v1, code=500, details=null, kind=Status, message=a
watch stream was requested by the client but the required storage feature
RequestWatchProgress is disabled, metadata=ListMeta(_continue=null,
remainingItemCount=null, resourceVersion=null, selfLink=null,
additionalProperties={}), reason=InternalError, status=Failure,
additionalProperties={}), will
retry","endOfBatch":false,"loggerFqcn":"org.apache.logging.slf4j.Log4jLogger","contextMap":{},"threadId":82,"threadPriority":5}{code}
After some investigation, it appears the Kubernetes client library used by the
Flink operator may be outdated and incompatible with Kubernetes 1.32?
Reference:
https://github.com/apache/flink-kubernetes-operator/blob/release-1.12.0/pom.xml#L81
Support for Kubernetes 1.32 was introduced in client version 7.1.0.
Thanks.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
