From 0791373fb2245278cd916d8c2b224887a2a9f4b5 Mon Sep 17 00:00:00 2001 From: Sergey Nuyanzin Date: Fri, 24 Jul 2026 10:05:41 +0200 Subject: [PATCH] [FLINK-40231][tests] Fix flaky HistoryServerArchiveFetcherTest#testArchiveStateTransition --- .../webmonitor/history/HistoryServerArchiveFetcher.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) 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); }