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 158296f86b..908aaa2183 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 IPage 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()); } @@ -763,12 +764,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;