[Improvement] Get flinkClient error, the error is: io.fabric8.kubernetes.client.KubernetesClientException: An error has occurred.

[xinzhuxiansheng]

Search before asking

• I had searched in the issues and found no similar issues.

Java Version

jdk1.8

Scala Version

2.12.x

StreamPark Version

2.1.5

Flink Version

flink version 1.15.3

Deploy mode

kubernetes-application

What happened

I encountered a problem when upgrading the existing streampark environment 2.1.3 to version 2.1.5. As shown below, the log will continuously print "[StreamPark] Get flinkClient error, the error is: io.fabric8.kubernetes.client.KubernetesClientException: An error has occurred.", and eventually the StreamPark service will trigger an OOM exception, causing the Pod to die. However, these exception logs cannot provide me with a basis for investigation. I think it must be optimized here, which can tell me which job caused it.

我在处理已有的 streampark 环境2.1.3，升级到 2.1.5 版本时遇到的问题，如下所示， log 会不断打印 “[StreamPark] Get flinkClient error, the error is: io.fabric8.kubernetes.client.KubernetesClientException: An error has occurred. ”， 最终 StreamPark 服务会触发 OOM异常，而导致 Pod 死亡。 但是这些异常 log 无法给我提供排查依据，我想这里肯定优化它，它可以告诉我是哪个job引起的。

Error Exception

[StreamPark] Get flinkClient error, the error is: io.fabric8.kubernetes.client.KubernetesClientException: An error has occurred.

Screenshots

Are you willing to submit PR?

• Yes I am willing to submit a PR!(您是否要贡献这个PR?)

Code of Conduct

• I agree to follow this project's Code of Conduct

[xinzhuxiansheng]

My streampark is deployed on k8s, and the service OOM. Later, I configured jvm_opts.sh on the config map resource and then mounted it on the streampark yaml service. I increased the jvm heap memory size parameter and solved the above problem. I will close the issue

我的 streampark 部署在 k8s 上的，服务 OOM ，后面将 jvm_opts.sh 配置在 config map 资源上，然后将它挂载到 streampark yaml 服务上，我增加了 jvm 堆内存大小的参数，解决了上面的问题。 我将把 issue close掉