Hi,
Excellent, thanks for pointing this out! The definition in Watermark.java, which is used by HeapInternalTimerService.java, WindowOperator.isWindowLate() and WindowOperator.isElementLate() and is also documented in [1] is the definitive (ha!) definition.
I created Jira issues for fixing these:
- FLINK-7563 - Fix watermark semantics in CEP operators <
https://issues.apache.org/jira/browse/FLINK-7563>
- FLINK-7564 - Fix Watermark semantics in Table API <
https://issues.apache.org/jira/browse/FLINK-7564>
Best,
Aljoscha