I don't think this is necessary. It depends on the semantics of the source how to deal with multiple states. This cannot be inferred from the example. I would keep it as it is.
[ Full content available at: https://github.com/apache/flink/pull/6625 ] This message was relayed via gitbox.apache.org for [email protected]
