Skip to content

Commit df68b24

Browse files
authored
[Bug] Fix duration column in JobList & JobDetail (#4242)
1 parent 2d51eb0 commit df68b24

File tree

1 file changed

+9
-8
lines changed

1 file changed

+9
-8
lines changed

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

Lines changed: 9 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -276,15 +276,16 @@ public IPage<FlinkApplication> page(FlinkApplication appParam, RestRequest reque
276276
.peek(
277277
record -> {
278278
// status of flink job on kubernetes mode had been automatically persisted
279-
// to db
280-
// in time.
279+
// to db in time.
281280
if (record.isKubernetesModeJob()) {
282-
// set duration
283281
String restUrl = k8SFlinkTrackMonitor
284282
.getRemoteRestUrl(k8sWatcherWrapper.toTrackId(record));
285283
record.setFlinkRestUrl(restUrl);
286-
setAppDurationIfNeeded(record, now);
287284
}
285+
286+
// set duration
287+
setAppDurationIfNeeded(record, now);
288+
288289
if (pipeStates.containsKey(record.getId())) {
289290
record.setBuildStatus(pipeStates.get(record.getId()).getCode());
290291
}
@@ -762,12 +763,12 @@ public FlinkApplication getApp(Long id) {
762763
if (application.isKubernetesModeJob()) {
763764
String restUrl = k8SFlinkTrackMonitor.getRemoteRestUrl(k8sWatcherWrapper.toTrackId(application));
764765
application.setFlinkRestUrl(restUrl);
765-
766-
// set duration
767-
long now = System.currentTimeMillis();
768-
setAppDurationIfNeeded(application, now);
769766
}
770767

768+
// set duration
769+
long now = System.currentTimeMillis();
770+
setAppDurationIfNeeded(application, now);
771+
771772
application.setYarnQueueByHotParams();
772773

773774
return application;

0 commit comments

Comments
 (0)