[Bug] Flink on k8s env bug

[davidyuan1223]

Search before asking

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

Java Version

1.8

Scala Version

2.11.x

StreamPark Version

2.1.4

Flink Version

1.14

Deploy mode

kubernetes-application

What happened

env: Flink 1.14 on k8s
reproduction:

1. config a error FlinkSQL but could verify success
2. release and start this job, the flink on k8s jobmanager will start failed
3. update the sql content, re release&start, this job also failed, see the log could found it is run the old version sql, not the newest sql
4. the jobmanager on k8s will repeat restart
5. when you try to delete the job
6. the job config on streampark will delete the config, but in k8s cluster, the wrong jobmanager will always restart again, it will reduce the k8s resource, and people could not found that

Error Exception

Screenshots

like this

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

[davidyuan1223]

i think the delete job, maybe we need call kubectl delete deployment xxx -n namespace to delete the deployment, because the eroor jobmanager will restart