Piotr Nowojski created FLINK-12777: -------------------------------------- Summary: Support CheckpointBarrierHandler in StreamTwoInputSelectableProcessor Key: FLINK-12777 URL: https://issues.apache.org/jira/browse/FLINK-12777 Project: Flink Issue Type: Sub-task Reporter: Piotr Nowojski Assignee: Piotr Nowojski Fix For: 1.9.0
Implement new {{CheckpointBarrierHandler}} in such a way, that it will work with {{StreamTaskNetworkInput}} in context of {{StreamTwoInputSelectableProcessor}} (assuming static/constant {{InputSelection.ANY}}) -- This message was sent by Atlassian JIRA (v7.6.3#76005)