[FLINK-19265] Simplify handling of 'NoMoreSplitsEvent'

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.11.3, 1.12.0
• Component/s: Connectors / Common
• Labels: pull-request-available
• Assignee: Stephan Ewen
• Reporter: Stephan Ewen
• Created: 16/Sep/20 16:32
• Updated: 12/Dec/20 11:53
• Resolved: 09/Nov/20 23:41

Description

Split assignment events are treated specially by the source API. Users do not create them directly but call methods on the contexts to assign splits.

The NoMoreSplitsEvent is in contrast to that a custom user event and needs to be handled like a custom event, when sent by enumerators and received by the readers.

That seems a bit confusing and inconsistent, given that NoMoreSplits is essential for all bounded stream use cases and is on the same level as the AddSplitEvent.

I suggest that we treat "no more splits" similarly, by having either a custom method or a custom "SplitAssignment" on the context and reader.

jqin Curious what would be your take on this.

Issue Links

• links to: GitHub Pull Request #13988