kfaraz commented on code in PR #18312:
URL: https://github.com/apache/druid/pull/18312#discussion_r2224679183
##########
indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamIndexTaskRunner.java:
##########
@@ -814,7 +814,13 @@ public void onFailure(Throwable t)
catch (Exception e) {
// (1) catch all exceptions while reading from kafka
caughtExceptionInner = e;
- log.error(e, "Encountered exception in run() before persisting.");
+ if (e instanceof InterruptedException || (e.getCause() != null
+ && e.getCause() instanceof
InterruptedException)) {
+ // InterruptedException stack trace is not that useful and will clog
up the logs.
Review Comment:
```suggestion
if (e instanceof InterruptedException || (Throwables.getRootCause(e)
instanceof InterruptedException)) {
// Suppress InterruptedException stack trace to avoid flooding the
logs
```
--
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]
