You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ma...@apache.org on 2026/07/09 12:11:59 UTC
(flink) 04/05: [FLINK-39921][runtime/tests] Fix the flaky test case ExecutionVertexCancelTest.testSendCancelAndReceiveFail (#28449)
This is an automated email from the ASF dual-hosted git repository.
MartijnVisser pushed a commit to branch release-2.2
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 09377371e9539d5c50ead5b6454cec80483b0dfa
Author: Chan hae OH <45...@users.noreply.github.com>
AuthorDate: Sat Jun 20 12:21:45 2026 +0900
[FLINK-39921][runtime/tests] Fix the flaky test case ExecutionVertexCancelTest.testSendCancelAndReceiveFail (#28449)
(cherry picked from commit a8d6a287ae280fc357d85d7f2efe08c561c8e02e)
---
.../flink/runtime/executiongraph/ExecutionVertexCancelTest.java | 9 ++++++---
1 file changed, 6 insertions(+), 3 deletions(-)
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionVertexCancelTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionVertexCancelTest.java
index 35c65ec1763..91f0bdb7e73 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionVertexCancelTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionVertexCancelTest.java
@@ -19,8 +19,9 @@
package org.apache.flink.runtime.executiongraph;
import org.apache.flink.api.common.JobStatus;
-import org.apache.flink.runtime.concurrent.ComponentMainThreadExecutorServiceAdapter;
+import org.apache.flink.runtime.concurrent.NoMainThreadCheckComponentMainThreadExecutor;
import org.apache.flink.runtime.execution.ExecutionState;
+import org.apache.flink.runtime.executiongraph.utils.ExecutionUtils;
import org.apache.flink.runtime.executiongraph.utils.SimpleAckingTaskManagerGateway;
import org.apache.flink.runtime.jobgraph.JobGraphTestUtils;
import org.apache.flink.runtime.jobmaster.LogicalSlot;
@@ -247,12 +248,14 @@ class ExecutionVertexCancelTest {
final SchedulerBase scheduler =
SchedulerTestingUtils.createScheduler(
JobGraphTestUtils.streamingJobGraph(createNoOpVertex(10)),
- ComponentMainThreadExecutorServiceAdapter.forMainThread(),
+ new NoMainThreadCheckComponentMainThreadExecutor(),
EXECUTOR_RESOURCE.getExecutor());
final ExecutionGraph graph = scheduler.getExecutionGraph();
scheduler.startScheduling();
-
+ for (ExecutionVertex ev : graph.getAllExecutionVertices()) {
+ ExecutionUtils.waitForTaskDeploymentDescriptorsCreation(ev);
+ }
ExecutionGraphTestUtils.switchAllVerticesToRunning(graph);
assertThat(graph.getState()).isEqualTo(JobStatus.RUNNING);