This is an automated email from the ASF dual-hosted git repository. MartijnVisser pushed a commit to branch release-2.3 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 7759744237f934f3208e4aa605b04227d1e07123 Author: Chan hae OH <[email protected]> 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);
