Chanhae Oh created FLINK-39914:
----------------------------------
Summary: Fix flaky
TaskDeploymentDescriptorFactoryTest#testHybridVertexFinish caused by async TDD
creation
Key: FLINK-39914
URL: https://issues.apache.org/jira/browse/FLINK-39914
Project: Flink
Issue Type: Bug
Components: Runtime / Task
Affects Versions: 2.3.0
Reporter: Chanhae Oh
Fix For: 2.3.0
With the async TaskDeploymentDescriptor creation introduced in
Execution.deploy(), the IO executor thread now calls
jobMasterMainThreadExecutor.execute() to enqueue the TaskDeploymentDescriptor
creation step.
However, the test was using
ComponentMainThreadExecutorServiceAdapter.forMainThread(), whose execute()
method asserts that the caller is the registered main thread (the test thread).
Since Java assertions (-ea) are enabled in the test JVM, this triggers an
AssertionError when the IO executor thread calls execute().
The error propagates through the CompletableFuture chain, causing the producer
vertex to transition to FAILED state, which subsequently leads to an
IllegalStateException when the consumer vertex attempts to consume partitions
from the failed producer.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
