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
commit 923a359320702130264dcfeb43c139161c247fba Author: Yi Zhang <[email protected]> AuthorDate: Fri Mar 27 11:41:35 2026 +0800 [hotfix][runtime] Fix DispatcherCleanupITCase.testCleanupAfterLeadershipChange --- .../apache/flink/runtime/dispatcher/DispatcherCleanupITCase.java | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherCleanupITCase.java b/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherCleanupITCase.java index da202b0dc44..4eca35fc00f 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherCleanupITCase.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherCleanupITCase.java @@ -318,6 +318,8 @@ public class DispatcherCleanupITCase extends AbstractDispatcherTest { waitForJobToFinish(confirmedLeaderInformation, dispatcherGateway, jobId); firstCleanupTriggered.await(); + CommonTestUtils.waitUntilCondition( + () -> !haServices.getApplicationResultStore().getDirtyResults().isEmpty()); assertThat(actualGlobalCleanupCallCount.get()) .as("The cleanup should have been triggered only once.") @@ -335,12 +337,6 @@ public class DispatcherCleanupITCase extends AbstractDispatcherTest { .collect(Collectors.toSet())) .as("The JobResultStore should have this job marked as dirty.") .containsExactly(jobId); - assertThat( - haServices.getApplicationResultStore().getDirtyResults().stream() - .map(ApplicationResult::getApplicationId) - .collect(Collectors.toSet())) - .as("The ApplicationResultStore should have this application marked as dirty.") - .containsExactly(applicationId); // Run a second dispatcher, that restores our finished job. final Dispatcher secondDispatcher =
