[jira] [Updated] (FLINK-37982) When watermark is updated, the result that outputs in TableAsyncExecutionController cannot be triggered

["Qilong Wang (Jira)" <ji...@apache.org>]

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

Qilong Wang updated FLINK-37982:
--------------------------------
    Summary: When watermark is updated, the result that outputs in TableAsyncExecutionController cannot be triggered  (was: When Watermark is updated, the result output in TableAsyncExecutionController cannot be triggered)

> When watermark is updated, the result that outputs in TableAsyncExecutionController cannot be triggered
> -------------------------------------------------------------------------------------------------------
>
>                 Key: FLINK-37982
>                 URL: https://issues.apache.org/jira/browse/FLINK-37982
>             Project: Flink
>          Issue Type: Bug
>          Components: Table SQL / Runtime
>    Affects Versions: 2.1.0
>            Reporter: Qilong Wang
>            Priority: Major
>
> When execute processWatermark in TableKeyedAsyncWaitOperator, all results cannot be triggered because mailboxExecutor cannot execute until `endInput` because of `mailboxExecutor.yield()`
> Only one case can avoid above, that is the totalInflightNum is greater than capacity. But if processElement data cannot be more than capacity, data will never be sent downstream.



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