[incubator-streampark] branch dev updated: [bug]batch job end ingress is not deleted (#1986)

[benjobs]

This is an automated email from the ASF dual-hosted git repository.

benjobs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git


The following commit(s) were added to refs/heads/dev by this push:
     new d52f48284 [bug]batch job end ingress is not deleted (#1986)
d52f48284 is described below

commit d52f482849494ddaf52369794853fc30ac949428
Author: monster <60029759+monsterchenz...@users.noreply.github.com>
AuthorDate: Tue Nov 8 17:25:10 2022 +0800

    [bug]batch job end ingress is not deleted (#1986)
    
    * [bug]batch job end ingress is not deleted
---
 .../streampark/console/core/task/K8sFlinkChangeEventListener.java    | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/K8sFlinkChangeEventListener.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/K8sFlinkChangeEventListener.java
index 858999b53..04fcbe77e 100644
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/K8sFlinkChangeEventListener.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/task/K8sFlinkChangeEventListener.java
@@ -164,9 +164,6 @@ public class K8sFlinkChangeEventListener {
         // update relevant fields of Application from JobStatusCV
         app.setJobId(jobStatus.jobId());
         app.setTotalTask(jobStatus.taskTotal());
-        if (FlinkJobState.isEndState(state)) {
-            app.setOptionState(OptionState.NONE.getValue());
-        }
 
         // corrective start-time / end-time / duration
         long preStartTime = app.getStartTime() != null ? 
app.getStartTime().getTime() : 0;
@@ -178,6 +175,8 @@ public class K8sFlinkChangeEventListener {
         long duration = jobStatus.duration();
 
         if (FlinkJobState.isEndState(state)) {
+            IngressController.deleteIngress(app.getJobName(), 
app.getK8sNamespace());
+            app.setOptionState(OptionState.NONE.getValue());
             if (endTime < startTime) {
                 endTime = System.currentTimeMillis();
             }