[FLINK-12777] Support CheckpointBarrierHandler in StreamTwoInputSelectableProcessor

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.9.0
• Component/s: Runtime / Task
• Labels: pull-request-available
• Assignee: Piotr Nowojski
• Reporter: Piotr Nowojski
• Created: 07/Jun/19 12:14
• Updated: 01/Jul/19 14:42
• Resolved: 01/Jul/19 14:42

Description

Implement new CheckpointBarrierHandler in such a way, that it will work with StreamTaskNetworkInput in context of StreamTwoInputSelectableProcessor (assuming static/constant InputSelection.ANY)

Issue Links

• links to: GitHub Pull Request #8811