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)
