[FLINK-15776] Rework 2-phase commit abstractions

• Type: Improvement
• Status: Closed
• Priority: Not a Priority
• Resolution: Cannot Reproduce
• Affects Version/s: 1.10.0
• Component/s: Connectors / Common
• Labels: auto-deprioritized-major auto-deprioritized-minor
• Assignee: Unassigned
• Reporter: Roman Khachatryan
• Created: 27/Jan/20 12:08
• Updated: 22/Nov/21 18:36
• Resolved: 22/Nov/21 18:36

Description

While implementing JDBC exactly once sink I found that the current abstractions (TwoPhaseCommitSinkFunction) don’t suit this use case. Having a requirement to avoid code duplication, I propose a new set abstractions.

See the corresponding FLIP-94.

Issue Links

• mentioned in: Page Loading...