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 94f13eb58c7..60c5891afaf 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 class SpecificSegmentQueryRunner implements QueryRunner 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 baseSequence;