Github user xccui commented on the issue:
https://github.com/apache/flink/pull/4633
Thanks for the review, @fhueske. I tried to consolidate the logics for
proctime and rowtime watermark processing, but failed. That's because when
using proctime, the "watermark" (not sure if this concept exists for proctime)
for triggering the timers is set to be identical with the current record's
processing time, thus all the records will be considered late. Do you think
it's necessary to unify their behaviors, or we just take the proctime as a
special case?
---
