[jira] [Created] (FLINK-39914) Fix flaky TaskDeploymentDescriptorFactoryTest#testHybridVertexFinish caused by async TDD creation

["Chanhae Oh (Jira)" <ji...@apache.org>]

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)