Piotr Nowojski created FLINK-16317: -------------------------------------- Summary: Implement missing features for MultipleInputStreamOperator Key: FLINK-16317 URL: https://issues.apache.org/jira/browse/FLINK-16317 Project: Flink Issue Type: Sub-task Components: API / DataStream, Runtime / Task Affects Versions: 1.10.0 Reporter: Piotr Nowojski Fix For: 1.11.0
After https://issues.apache.org/jira/browse/FLINK-16060 support for {{MultipleInputStreamOperator}} is incomplete. After defining new base class for the {{StreamOperator}} (FLINK-15687) 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)