Github user tweise commented on the issue: https://github.com/apache/flink/pull/5480 @tzulitai see https://gist.github.com/tweise/7fad5d5df0abf54670a52d0d02d61179 for details. As indicated in the email thread, emit override will track watermark state and delegate the record to the base implementation.
---