[Bug] fix duration column in JobList & JobDetail

Author: Gianzie

streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/application/impl/FlinkApplicationManageServiceImpl.java

@@ -282,15 +282,16 @@ public IPage<FlinkApplication> page(FlinkApplication appParam, RestRequest reque
             .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());
                     }
@@ -776,12 +777,12 @@ public FlinkApplication getApp(Long id) {
         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;