From bf1d791196af5c2cab5c1c7bd50811459d52afdb Mon Sep 17 00:00:00 2001
From: Karan Kumar <karankumar1100@gmail.com>
Date: Tue, 10 Oct 2023 05:59:03 +0530
Subject: [PATCH] Add query id to processing pool thread name. (#15059)

This patch changes the thread name of the processing pool of the indexers/peons/historicals from query.getType() + "_" + query.getDataSource() + "_" + query.getIntervals() to query.getId()
---
 .../org/apache/druid/query/spec/SpecificSegmentQueryRunner.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/processing/src/main/java/org/apache/druid/query/spec/SpecificSegmentQueryRunner.java b/processing/src/main/java/org/apache/druid/query/spec/SpecificSegmentQueryRunner.java
index 94f13eb58c74..60c5891afafc 100644
--- a/processing/src/main/java/org/apache/druid/query/spec/SpecificSegmentQueryRunner.java
+++ b/processing/src/main/java/org/apache/druid/query/spec/SpecificSegmentQueryRunner.java
@@ -74,7 +74,7 @@ public Sequence<T> run(final QueryPlus<T> input, final ResponseContext responseC
 
     final Thread currThread = setName ? Thread.currentThread() : null;
     final String currThreadName = setName ? currThread.getName() : null;
-    final String newName = setName ? query.getType() + "_" + query.getDataSource() + "_" + query.getIntervals() : null;
+    final String newName = setName ? "processing_" + query.getId() : null;
 
     final Sequence<T> baseSequence;