[FLINK-16317] Add watermarks, keyed state and latency markers support for MultipleInputStreamOperator

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.10.0
• Fix Version/s: 1.11.0
• Component/s: API / DataStream, Runtime / Task
• Labels: pull-request-available
• Assignee: Piotr Nowojski
• Reporter: Piotr Nowojski
• Created: 27/Feb/20 15:01
• Updated: 26/Mar/20 10:50
• Resolved: 26/Mar/20 10:49

Description

After FLINK-16060 support for MultipleInputStreamOperator is incomplete. After defining new base class for the StreamOperator (FLINK-16316) that would be suitable to use with MultipleInputStreamOperator, we can provide support for missing features in the MultipleInputStreamOperator, like:

• keyed state support
• processing Watermark
• processing LatencyMarker
• StreamStatus

Issue Links

• is cloned by: FLINK-16806 Implement Input selection for MultipleInputStreamOperator
• links to: GitHub Pull Request #11467