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);
}