Feelitx opened a new pull request, #55481: URL: https://github.com/apache/spark/pull/55481
### What changes were proposed in this pull request? This PR un-skips the Connect parity test `test_streaming_foreach_batch_graceful_stop` and applies the retry-timeout infrastructure introduced in SPARK-52843 (`@eventually` and `@timeout`). Additionally, it replaces the py4j-specific `_jvm.java.lang.Thread.sleep()` call with standard Python `time.sleep()`. ### Why are the changes needed? This resolves [SPARK-56565](https://issues.apache.org/jira/browse/SPARK-56565). The test for `foreachBatch` graceful stop was previously skipped for Connect because it inherently relied on Py4J's pinned thread execution model and caused flaky timeout behaviors. With the new retry infrastructure, we can safely re-enable it for the Connect module. ### Does this PR introduce _any_ user-facing change? No. ### How was this patch tested? Verified by standard GitHub Actions on personal fork. ### Was this patch authored or co-authored using generative AI tooling? No. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
