You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampark.apache.org by be...@apache.org on 2022/11/08 09:25:17 UTC
[incubator-streampark] branch dev updated: [bug]batch job end ingress is not deleted (#1986)
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 <60...@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();
}