From f2943a875db6b9b381fdad4459cc69b4c3d0a2ba Mon Sep 17 00:00:00 2001 From: MukundaKatta Date: Wed, 15 Apr 2026 00:10:48 -0700 Subject: [PATCH] Fix typos `Encounted InterrupedException` in SeekableStreamIndexTaskRunner log Two adjacent misspellings on the same log line: `Encounted` -> `Encountered` and `InterrupedException` -> `InterruptedException`. Log string only; no behaviour change. Fixes #19189 --- .../indexing/seekablestream/SeekableStreamIndexTaskRunner.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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."); }