Akanksha-kedia opened a new pull request, #17071: URL: https://github.com/apache/pinot/pull/17071
- Added a _stopReasonPrinted volatile flag to track if the stop reason has already been printed - Modified the endCriteriaReached() method to check this flag before logging the stop reason - Implemented support for a "stopOnDecodeError" configuration parameter in the StreamConfig - When enabled, consumption will stop with an error if a decode error occurs - When disabled (default), errors are logged and the row is silently dropped - These changes prevent redundant logging and provide flexible error handling options -- 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]
