rich7420 opened a new pull request, #6108: URL: https://github.com/apache/datafusion-comet/pull/6108
## Which issue does this PR close? Closes #6075. ## Rationale for this change Parquet writer tests can capture a delayed callback from a setup write and incorrectly report that the write under test fell back to Spark. ## What changes are included in this PR? Drain the listener bus before registering the listener and after the write using `CometListenerBusUtils.waitUntilEmpty`, replacing the polling loop. ## How are these changes tested? Existing writer suites pass locally on Spark 4.0.4 and 4.1.3 (50 tests each), and Spark 3.5.9 (38 passed, 11 canceled by existing version gates). [Fork CI](https://github.com/rich7420/datafusion-comet/pull/33/checks) passes across Spark profiles. -- 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]
