Skip to content

[Spark 4] Filter late data against the key's previous watermark in the streaming stateful ParDo - #40447

Merged
Abacn merged 3 commits into
apache:masterfrom
tkaymak:spark4-streaming-watermark-lag
Oct 12, 2026
Merged

Abacn merged 3 commits into
apache:masterfrom
tkaymak:spark4-streaming-watermark-lag

Test SparkTimerInternals.forWatermarks

9b64737
Select commit
Loading
Failed to load commit list.
Sign in for the full log view

Annotations

1 warning and 1 notice
process-pr-update
succeeded Oct 7, 2026 in 28s