Add query id to processing pool thread name. (apache#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()
ektravel · Oct 16, 2023 · bf1d791 · bf1d791
1 parent af8c4de
commit bf1d791
Showing 1 changed file with 1 addition and 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
@@ -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;