jerrypeng opened a new pull request #12278:
URL: https://github.com/apache/pulsar/pull/12278


   ### Motivation
   
   There are situations where it is useful for localrun to exit if the instance 
it is running encounters an error.  This is useful for situations where the 
localrun is being orchestrated by a scheduler like K8s.  If there are errors in 
the function, it is easier to detect, observe, and alert on issues if the 
localrun is consisting exiting / crash loop.
   
   ### Modifications
   
   1. Allow localrun to exist if the function encounters an error
   2. Fix inconsistencies in Pulsar IO Sink error handling.  Currently, if a 
Pulsar IO sink throws exception during write.  The error is only logged and not 
bubble up which is different than the behavior for functions and sources.
   
   ### Verifying this change
   
   Add tests.


-- 
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]


Reply via email to