[incubator-streampark] branch batch updated: [bug]batch job end ingress is not deleted

[monster]

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

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


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

commit 2eafcd3a3a3f66fcab17539a0663a9c0107dad26
Author: Monster <2572805...@qq.com>
AuthorDate: Tue Nov 8 15:31:38 2022 +0800

    [bug]batch job end ingress is not deleted
---
 .../apache/streampark/console/core/task/K8sFlinkChangeEventListener.java | 1 +
 1 file changed, 1 insertion(+)

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..a48adf7c1 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
@@ -165,6 +165,7 @@ public class K8sFlinkChangeEventListener {
         app.setJobId(jobStatus.jobId());
         app.setTotalTask(jobStatus.taskTotal());
         if (FlinkJobState.isEndState(state)) {
+            IngressController.deleteIngress(app.getJobName(), 
app.getK8sNamespace());
             app.setOptionState(OptionState.NONE.getValue());
         }