This is an automated email from the ASF dual-hosted git repository.
zhuzh 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 3cf73f3d809 [FLINK-39164][history] Fix HistoryServerTest by adding
delay to avoid identical archive timestamps
3cf73f3d809 is described below
commit 3cf73f3d809d18b7f7829447ce719ce4fd8aef4e
Author: Yi Zhang <[email protected]>
AuthorDate: Wed Feb 25 19:24:54 2026 +0800
[FLINK-39164][history] Fix HistoryServerTest by adding delay to avoid
identical archive timestamps
---
.../apache/flink/runtime/webmonitor/history/HistoryServerTest.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
diff --git
a/flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/history/HistoryServerTest.java
b/flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/history/HistoryServerTest.java
index 9d5f912fd26..91c213e6d97 100644
---
a/flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/history/HistoryServerTest.java
+++
b/flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/history/HistoryServerTest.java
@@ -647,6 +647,9 @@ class HistoryServerTest {
expectedApplicationAndJobIdsToKeep.add(
new Tuple2<>(applicationId, new HashSet<>(jobIds)));
}
+ // Sleep to ensure archive files have distinct timestamps.
Identical timestamps can lead
+ // to non-deterministic eviction order, causing test flakiness.
+ Thread.sleep(50);
}
// one for application itself, numJobsPerApplication for jobs
@@ -716,7 +719,8 @@ class HistoryServerTest {
.collect(Collectors.toList());
expectedApplicationAndJobIdsToKeep.add(
new Tuple2<>(applicationId, new HashSet<>(jobIds)));
- // avoid executing too fast, resulting in the same creation
time of archive files
+ // Sleep to ensure archive files have distinct timestamps.
Identical timestamps can
+ // lead to non-deterministic eviction order, causing test
flakiness.
Thread.sleep(50);
}