Stephan Ewen created FLINK-17903:
------------------------------------
Summary: Evolve WatermarkOutputMultiplexer to make it reusable in
FLIP-27 Sources
Key: FLINK-17903
URL: https://issues.apache.org/jira/browse/FLINK-17903
Project: Flink
Issue Type: Sub-task
Components: API / DataStream
Reporter: Stephan Ewen
Assignee: Stephan Ewen
Fix For: 1.11.0
The {{WatermarkOutputMultiplexer}} merges multiple independently generated
watermarks.
To make it usable in the FLIP-27 sources, we need to
- Change its IDs from integers to Strings (match splitIDs)
- Support de-registration of local outputs (when splits are finished)
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
