Skip to content

[Spark 4] Clear the watermark of keys without timers or state in the streaming stateful ParDo - #40550

Merged
Abacn merged 2 commits into
apache:masterfrom
schizophrenicmaniac:fix/40517-task-clear-per-key-watermark-and-timer
Oct 20, 2026
Merged

[Spark 4] Clear the watermark of keys without timers or state in the streaming stateful ParDo#40550
Abacn merged 2 commits into
apache:masterfrom
schizophrenicmaniac:fix/40517-task-clear-per-key-watermark-and-timer

[Spark 4] Drop the late element from the expired key test and state t…

ce85c06
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 20, 2026 in 23s