[SPARK-56586][CONNECT][TESTS] Bound and retry the flaky python foreachBatch termination test#55786

Closed

LuciferYang wants to merge 16 commits intoapache:masterfrom

LuciferYang:fix-foreach-batch-flaky-test

Commits on Apr 29, 2026

[TESTS] Wrap flaky SparkConnectSessionHolderSuite python foreachBatch test with retry + timeout
zhengruifeng
committed
[TESTS] Extract foreachBatch termination test body into a private method
zhengruifeng
committed
[TESTS] Tighten per-attempt timeout from 2 minutes to 1 minute
zhengruifeng
committed
[TESTS] Bound test body on a dedicated thread instead of failAfter
zhengruifeng
committed
[TESTS] Reformat awaitTestBodyInNewThread for scalafmt
zhengruifeng
committed
[TESTS] Make retry attempts resilient to leaked streaming queries
zhengruifeng
committed
[TESTS] Use System.nanoTime() for the query-name suffix
zhengruifeng
committed
[TESTS] Surface retry events in the GitHub Actions job log
zhengruifeng
committed
[TESTS] Force-unblock the hung worker on timeout by closing Python sockets
zhengruifeng
committed
[TESTS] Reformat awaitTestBodyInNewThread signature for scalafmt
zhengruifeng
committed

Commits on Apr 30, 2026

Commits on May 9, 2026

format
LuciferYang
committed

Commits on May 10, 2026

Merge branch 'apache:master' into fix-foreach-batch-flaky-test
LuciferYang
authored

Commits on May 11, 2026