Piotr Nowojski created FLINK-16806: -------------------------------------- Summary: Implement Input selection for MultipleInputStreamOperator Key: FLINK-16806 URL: https://issues.apache.org/jira/browse/FLINK-16806 Project: Flink Issue Type: Sub-task Components: API / DataStream, Runtime / Task Affects Versions: 1.10.0 Reporter: Piotr Nowojski Assignee: Piotr Nowojski Fix For: 1.11.0
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}} * input selection -- This message was sent by Atlassian Jira (v8.3.4#803005)