This is an automated email from the ASF dual-hosted git repository.

snuyanzin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 952fad470af [FLINK-40231][tests] Fix flaky 
`HistoryServerArchiveFetcherTest#testArchiveStateTransition`
952fad470af is described below

commit 952fad470af61b26b24fb65d533a81bd08ead10b
Author: Sergey Nuyanzin <[email protected]>
AuthorDate: Mon Jul 27 07:06:33 2026 +0200

    [FLINK-40231][tests] Fix flaky 
`HistoryServerArchiveFetcherTest#testArchiveStateTransition`
---
 .../runtime/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 e667d9cd365..632551c8eb3 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 @@ public class HistoryServerArchiveFetcher<Entry> implements 
AutoCloseable {
 
         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);
     }
 

Reply via email to