[FLINK-12967] Change the input selection switching in StreamTwoInputSelectableProcessor#checkFinished to invoking the nextSelection method of the stream operator

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.9.0
• Labels: pull-request-available
• Assignee: Haibo Sun
• Reporter: Haibo Sun
• Created: 25/Jun/19 02:03
• Updated: 25/Jun/19 09:37
• Resolved: 25/Jun/19 09:37

Description

The runtime (`StreamTwoInputSelectableProcessor#checkFinished()`) switches the input selection when one input is finished, because `BoundedxInput.endInput()` was not supported before the PR#8731 (https://github.com/apache/flink/pull/8731) is merged. Now we should change the logic of `StreamTwoInputSelectableProcessor#checkFinished()` to invoke `InputSelectable#nextSelection()`, and the input selection should been switched in `endInput()` by the operator.

Issue Links

• links to: GitHub Pull Request #8864