[core][spark] Deduplicate a replayed Structured Streaming micro-batch - #9667

Open

zhuxiangyi wants to merge 7 commits into

apache:masterfrom

zhuxiangyi:spark-streaming-idempotent-commit

Commits on Sep 7, 2026

[core][spark] Deduplicate a replayed Structured Streaming micro-batch
zhuxiangyi
committed
ed5d47c

Commits on Sep 9, 2026

[core][spark] Bind the streaming commit user to the checkpoint incarnation
zhuxiangyi
committed
5931ce7

Commits on Sep 12, 2026

[core][spark] Recognise a replay on the direct postpone committer too
zhuxiangyi
committed
587ad9c
[core][spark] Retry commit callbacks for a replayed micro-batch on the direct postpone path
zhuxiangyi
committed
e7a9976

Commits on Sep 13, 2026

Commits on Sep 14, 2026

[spark] Commit a micro-batch under an identifier counted from 1
zhuxiangyi
committed
f9995d4