[FLINK-25661] Add Custom Fatal Exception handler in AsyncSinkWriter

• Type: Improvement
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.15.0
• Component/s: Connectors / Common
• Labels: pull-request-available stale-assigned

Language

java

• Assignee: Nir Tsruya
• Reporter: Nir Tsruya
• Created: 16/Jan/22 10:07
• Updated: 21/Mar/22 10:43

Description

Motivation

User stories:
As a Flink user, I’d like to use configure a custom fatal exception handler to the AsyncSinkWriter

Scope:

• Create a new fatal exception handler
• Users of the AsyncSink should be able to create an implementation and pass it to the sink

Issue Links

• links to: GitHub Pull Request #18449