You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Yuepeng Pan (Jira)" <ji...@apache.org> on 2026/06/14 01:35:00 UTC

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

     [ https://issues.apache.org/jira/browse/FLINK-39914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Yuepeng Pan reassigned FLINK-39914:
-----------------------------------

    Assignee: Chanhae Oh

> 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
>            Assignee: Chanhae Oh
>            Priority: Minor
>              Labels: pull-request-available
>             Fix For: 2.3.0, 2.4.0
>
>         Attachments: image-2026-06-12-02-08-15-099.png
>
>
> Execution.deploy() now creates TaskDeploymentDescriptor asynchronously, which means the IO executor thread calls jobMasterMainThreadExecutor.execute() to hand off the work.
>  The problem is that forMainThread() captures the calling thread at the time of its creation and asserts inside execute() that only that same thread can call it.
> Since the IO executor thread calls execute() instead, the assertion fires and throws an AssertionError. This error then bubbles up through the CompletableFuture chain, flipping the producer vertex into FAILED state, which causes an IllegalStateException when the consumer vertex tries to read from it.
>  
> !image-2026-06-12-02-08-15-099.png|width=623,height=451!



--
This message was sent by Atlassian Jira
(v8.20.10#820010)