dongjoon-hyun opened a new pull request, #446: URL: https://github.com/apache/spark-connect-swift/pull/446
### What changes were proposed in this pull request? This PR aims to fix `DataFrame.execute()` to throw an error when `ArrowReader.fromMessage` fails, instead of ignoring the returned `Result`. In addition, `ArrowReader.fromMessage` now returns `.failure` instead of force-unwrapping `result.messageSchema!` when a record batch arrives before the schema. ### Why are the changes needed? Previously, a schema load failure (e.g., an unsupported Arrow type) crashed the process on the force-unwrap, and a record-batch load failure silently dropped data from `collect()` results. ### Does this PR introduce _any_ user-facing change? No. Failures which previously crashed or silently dropped data now throw an error. ### How was this patch tested? Pass the CIs. ### Was this patch authored or co-authored using generative AI tooling? Generated-by: Claude Fable 5 -- 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]
