[spark] Clean up orphan files left by Spark speculative execution - #8927

Open

hbgstc123 wants to merge 12 commits into

apache:masterfrom

hbgstc123:spark-speculative-writer-cleanup

Commits on Aug 9, 2026

[spark] Clean up orphan files left by Spark speculative execution
hbg
committed
0eee6d0
Fix spotless formatting violations in paimon-core
hbg
committed
6654f27
Fix spotless formatting violations in paimon-spark-common
hbg
committed
8b312de
Fix Scala compile errors for prepareCommit Consumer callback
hbg
committed
05f5843
[core] Delete extra files when aborting uncommitted data files
hbg
committed
df35eb5
[core] Invoke onPrepared immediately after draining bucket increments
hbg
committed
d4df3f4
[core] Delete auxiliary files when closing unprepared append writers
hbg
committed
07243ec
Fix spotless formatting in PrimaryKeyIndexWriteTest
hbg
committed
f7517be
[spark] Fix FormatTable commitImpl Seq type for Scala 2.13
hbg
committed
23607ee
[core] Keep Flink prepareCommit maintainer ordering for idle writer cleanup
hbg
committed
ef135a3
[core] Use Spark prepareCommit ordering only when onPrepared is set
hbg
committed
ccf93ad
[core] Route Flink TableWrite prepareCommit through 2-arg overload
hbg
committed
6da16ea