stream-join-watermark-monotonic

Status: IN

The join processor's watermark only advances forward via `max(current, event.timestamp)`; `advance_time()` silently ignores timestamps at or below the current watermark

Source: entries/2026/05/29/stream-join-processor-stream_join_processor.md

Example

self._watermark = max(self._watermark, event.timestamp - self._allowed_lateness)

JSON