diff --git a/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerArchiveFetcher.java b/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerArchiveFetcher.java index e667d9cd36521..632551c8eb32d 100644 --- a/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerArchiveFetcher.java +++ b/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerArchiveFetcher.java @@ -623,7 +623,10 @@ ArchiveEvent lazyProcessJobArchive(String jobId, Path jobArchive, boolean indivi ArchiveEventType archiveEventType = overviewCreated ? ArchiveEventType.OVERVIEW_CREATED : ArchiveEventType.CREATED; - archiveMetaInfo.setEventType(archiveEventType); + if (detailArchives.isEmpty()) { + // otherwise the async task above is now the sole owner of eventType transitions. + archiveMetaInfo.setEventType(archiveEventType); + } return new ArchiveEvent(jobId, archiveEventType); }