KKcorps opened a new pull request, #10297: URL: https://github.com/apache/pinot/pull/10297
Currently if the primary thread is interruptted (either due to `fetchTimeout` or some other reason), the `Thread.sleep` throws an `InterrupttedException` which isn't handled. This leads to consumer not able to proceed beyond a certain number of records. The solution is to simply handled the exception. The exception is also caught outside the Kinesis exceptions because we don't need to LOG it really and only use it to break the `while` loop. That is the behavior we do while checking for `Thread.interrupted` as well. -- 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]
