Github user xccui commented on the issue:
https://github.com/apache/flink/pull/5016
Thanks for the review @fhueske. I think you are right. A dedicated
`WatermarkStrategy` with watermark-preserve semantics should be better. I'll
update the PR according to your comments. Thanks.---
