[FLINK-27878] [FLIP-232] Add Retry Support For Async I/O In DataStream API

• Type: New Feature
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.16.0
• Component/s: API / DataStream
• Labels: pull-request-available
• Release Note: This feature introduces a built-in retry mechanism for async operator which is transparently to user's existing code, it is flexibly to satisfy the retry and exception handling needs for users.
• Flags: Important
• Assignee: lincoln lee
• Reporter: lincoln lee
• Created: 02/Jun/22 08:04
• Updated: 23/Sep/22 18:27
• Resolved: 16/Jul/22 00:52

Description

FLIP-232: Add Retry Support For Async I/O In DataStream API
https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=211883963

Issue Links

• relates to: FLINK-29038 AsyncWaitOperatorTest.testProcessingTimeRepeatedCompleteOrderedWithRetry failed with AssertionError
• links to: GitHub Pull Request #19983