Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/4702 Thank you @aljoscha ! I moved unrelated code changes to PR https://github.com/apache/flink/pull/4707 Just curious that why Flink's Scala API has its own `OutputTag` class, rather than using `org.apache.flink.util.OutputTag`?
---