diff --git a/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamIndexTaskRunner.java b/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamIndexTaskRunner.java index c4fa66e1b9e9..12b89c282c16 100644 --- a/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamIndexTaskRunner.java +++ b/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamIndexTaskRunner.java @@ -811,7 +811,7 @@ public void onFailure(Throwable t) // (1) catch all exceptions while reading from kafka if (Throwables.getRootCause(e) instanceof InterruptedException) { // Suppress InterruptedException stack trace to avoid flooding the logs - log.error("Encounted InterrupedException in run() before persisting"); + log.error("Encountered InterruptedException in run() before persisting"); } else { log.error(e, "Encountered exception in run() before persisting."); }