[jira] [Created] (FLINK-17903) Evolve WatermarkOutputMultiplexer to make it reusable in FLIP-27 Sources

[Shang Yuanchun (Jira)]

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)