Dear Flink developers, I would like to open a discussion on FLIP 234 [1] to support retryable lookup join to solve delayed updates issue, as a pre-work for this solution, we proposed FLIP-232[2] which adds a generic retry support for Async I/O. We prefer to offer this retry capability via query hints, similar to new join hints proposed in FLINK-27625[3] & FLIP-204[4].
This feature is backwards compatible and transparently to connectors. For existing connectors which implements AsyncTableFunction, can easily enable async retry via the new join hint. [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-234%3A+Support+Retryable+Lookup+Join+To+Solve+Delayed+Updates+Issue+In+External+Systems [2] https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=211883963 [3] https://lists.apache.org/thread/jm9kg33wk9z2bvo2b0g5bp3n5kfj6qv8 [4] https://cwiki.apache.org/confluence/display/FLINK/FLIP-204:+Introduce+Hash+Lookup+Join Best, Lincoln Lee
