You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by zh...@apache.org on 2026/04/01 01:59:50 UTC
(flink) 02/02: [hotfix][runtime] Fix DispatcherCleanupITCase.testCleanupAfterLeadershipChange
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 <zh...@163.com>
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 =