Github user aljoscha commented on the issue:

    https://github.com/apache/flink/pull/5100
  
    Ah stupid, so we have to do it in the chain and in the input processors. 
Because the problem of operators overriding `processWatermark()` is real. 😅 


---

Reply via email to