Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5063
I see. The bad performance is related to way that you generate the
watermarks. Generating so many watermarks is very inefficient because you
processing many more watermarks than actual records (watermarks are always
broadcasted).
I'm not convinced that this is a scenario that we should optimize for.---
