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

Posted to dev@flink.apache.org by "lincoln lee (Jira)" <ji...@apache.org> on 2022/12/21 13:25:00 UTC

[jira] [Created] (FLINK-30477) Not properly blocking retries when timeout occurs in AsyncWaitOperator

lincoln lee created FLINK-30477:
-----------------------------------

             Summary: Not properly blocking retries when timeout occurs in AsyncWaitOperator
                 Key: FLINK-30477
                 URL: https://issues.apache.org/jira/browse/FLINK-30477
             Project: Flink
          Issue Type: Bug
          Components: API / DataStream
    Affects Versions: 1.16.0
            Reporter: lincoln lee


as user reported in ml https://lists.apache.org/thread/n1rqml8h9j8zkhxwc48rdvj7jrw2rjcy
there's issue in AsyncWaitOperator that it not properly blocking retries when timeout occurs

this happens when a retry timer is unfired and then the user function timeout was triggered first, the current RetryableResultHandlerDelegator doesn't take the timeout process properly and will cause more unexpected retries.



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