Dear Flink developers, I would like to open a discussion on FLIP 232 [1], for an extension of AsyncWaitOperator to support retry for user's asyncFunction.
To do so, new user interface will added to define the trigger condition for retry and when should retry. Internally, a delayed retry mechanism will be introduced. There's PoC for this FLIP [2][3], thanks Yun Gao for offline discussions and valuable comments. The new feature is backwards compatible that can recover from state which was generated by prior flink versions, and if no retry strategy enabled the behavior is as before. [1] https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=211883963 [2] based on timer trigger https://github.com/lincoln-lil/flink/pull/new/async-retry-timer [3] based on DelayQueue with pull fashion https://github.com/lincoln-lil/flink/pull/new/async-op-retry Best, Lincoln Lee
