micheal-o opened a new pull request, #45449:
URL: https://github.com/apache/spark/pull/45449

   ### What changes were proposed in this pull request?
   I merged a previous PR (https://github.com/apache/spark/pull/45299), that 
handles and classifies exceptions thrown in user provided functions for foreach 
batch sink. This change is to make it backward compatible in order not to break 
current users, since users may be depending on getting the user code error from 
the `StreamingQueryException.cause`
   
   
   ### Why are the changes needed?
   Backward compatible
   
   ### Does this PR introduce _any_ user-facing change?
   Yes, better error message with error class for ForeachBatchSink user 
function failures.
   
   ### How was this patch tested?
   updated existing tests
   
   ### 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]

Reply via email to