search

apache / incubator-streampark

Make stream processing easier! Easy-to-use streaming application development framework and operation platform.
https://streampark.apache.org/
Apache License 2.0
3.91k stars 1.01k forks source link

Issue occurs when forcefully stop job running in kubernetes application mode #2700

Open hunkw123456 opened 1 year ago

hunkw123456 commented 1 year ago

Search before asking

Java Version

java 8

Scala Version

2.12.x

StreamPark Version

2.0.0

Flink Version

1.13.2

deploy mode

kubernetes-application

What happened

A flink job has been started in k8s application mode. Its "Run Status" keeps RUNNING and data cleansing is ongoing. Then I wanner kill this job by "stop" button, after I clicked it, the status switched to CANCELLING. As it kept on status CANCELLING for minutes, I don't want to wait, then I clicked the "Forced Stop Application" button to kill it forcefully: (1) Error appears, which reads ingresses can't be removed in the namespace "k8s-application-test-2", but actually "k8s-application-test-2" is the application name I set, not the kubernetes namespace. (2) The pod raised by this job can be stopped, but the "Run Status" turned to FAILED.

Error Exception

No response

Screenshots

Forced Stop 1 Forced Stop 2 Forced Stop 3 Forced Stop 4 Forced Stop 5

Are you willing to submit PR?

Code of Conduct

hunkw123456 commented 1 year ago

This is a bug, you can address it like this:

StreamPark\streampark-console\streampark-console-service\src\main\java\org\apache\streampark\console\core\service\impl\ApplicationServiceImpl.java:

IngressController.deleteIngress(application.getK8sNamespace(), application.getJobName()); --> IngressController.deleteIngress(application.getJobName(), application.getK8sNamespace());