Safety lag subtracted from the probed MAX(__mj_UpdatedAt) before it is persisted as the incremental
watermark. Closes a commit-ordering skew: a source row whose __mj_UpdatedAt was stamped at write-time T1
but whose transaction COMMITS after the fingerprint probe (which already read a higher MAX = T2 > T1) would,
without this lag, be permanently excluded by the strict __mj_UpdatedAt > watermark filter on the next pass.
Storing MAX - overlap makes the next incremental RE-scan the last overlap window; the MERGE/ON CONFLICT
upsert is idempotent so re-scanning already-applied rows is harmless. The overlap only needs to exceed the
source's typical commit latency — longer skews are still backstopped by FULL_REBUILD_EVERY_N_INCREMENTAL_REFRESHES.
Safety lag subtracted from the probed
MAX(__mj_UpdatedAt)before it is persisted as the incremental watermark. Closes a commit-ordering skew: a source row whose__mj_UpdatedAtwas stamped at write-time T1 but whose transaction COMMITS after the fingerprint probe (which already read a higherMAX = T2 > T1) would, without this lag, be permanently excluded by the strict__mj_UpdatedAt > watermarkfilter on the next pass. StoringMAX - overlapmakes the next incremental RE-scan the lastoverlapwindow; the MERGE/ON CONFLICTupsert is idempotent so re-scanning already-applied rows is harmless. The overlap only needs to exceed the source's typical commit latency — longer skews are still backstopped by FULL_REBUILD_EVERY_N_INCREMENTAL_REFRESHES.