[ https://issues.apache.org/jira/browse/FLINK-16317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17067409#comment-17067409 ]
Piotr Nowojski commented on FLINK-16317: ---------------------------------------- Support for keyed state, watermarks, latency markers and stream status merged as 158e4478cb..1d5f447102 > 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 > Assignee: Piotr Nowojski > Priority: Major > Labels: pull-request-available > Fix For: 1.11.0 > > Time Spent: 20m > Remaining Estimate: 0h > > 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)