(streampark) branch dev updated: [Bug] Fix duration column in JobList & JobDetail (#4242)

[panyuepeng]

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

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


The following commit(s) were added to refs/heads/dev by this push:
     new df68b247a [Bug] Fix duration column in JobList & JobDetail (#4242)
df68b247a is described below

commit df68b247a32f667778f4f1968d3fd1848bdb1e90
Author: Gianzie <63688853+gian...@users.noreply.github.com>
AuthorDate: Tue Feb 24 11:05:36 2026 +0800

    [Bug] Fix duration column in JobList & JobDetail (#4242)
---
 .../impl/FlinkApplicationManageServiceImpl.java         | 17 +++++++++--------
 1 file changed, 9 insertions(+), 8 deletions(-)

diff --git 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationManageServiceImpl.java
 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationManageServiceImpl.java
index ddbb27cf1..0d18aab3d 100644
--- 
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationManageServiceImpl.java
+++ 
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationManageServiceImpl.java
@@ -276,15 +276,16 @@ public class FlinkApplicationManageServiceImpl extends 
ServiceImpl<FlinkApplicat
             .peek(
                 record -> {
                     // status of flink job on kubernetes mode had been 
automatically persisted
-                    // to db
-                    // in time.
+                    // to db in time.
                     if (record.isKubernetesModeJob()) {
-                        // set duration
                         String restUrl = k8SFlinkTrackMonitor
                             
.getRemoteRestUrl(k8sWatcherWrapper.toTrackId(record));
                         record.setFlinkRestUrl(restUrl);
-                        setAppDurationIfNeeded(record, now);
                     }
+
+                    // set duration
+                    setAppDurationIfNeeded(record, now);
+
                     if (pipeStates.containsKey(record.getId())) {
                         
record.setBuildStatus(pipeStates.get(record.getId()).getCode());
                     }
@@ -762,12 +763,12 @@ public class FlinkApplicationManageServiceImpl extends 
ServiceImpl<FlinkApplicat
         if (application.isKubernetesModeJob()) {
             String restUrl = 
k8SFlinkTrackMonitor.getRemoteRestUrl(k8sWatcherWrapper.toTrackId(application));
             application.setFlinkRestUrl(restUrl);
-
-            // set duration
-            long now = System.currentTimeMillis();
-            setAppDurationIfNeeded(application, now);
         }
 
+        // set duration
+        long now = System.currentTimeMillis();
+        setAppDurationIfNeeded(application, now);
+
         application.setYarnQueueByHotParams();
 
         return application;