diff --git a/server/src/main/java/io/druid/server/coordination/ServerManager.java b/server/src/main/java/io/druid/server/coordination/ServerManager.java index 6bc703297e5..8f545f492d2 100644 --- a/server/src/main/java/io/druid/server/coordination/ServerManager.java +++ b/server/src/main/java/io/druid/server/coordination/ServerManager.java @@ -390,30 +390,30 @@ public class ServerManager implements QuerySegmentWalker { SpecificSegmentSpec segmentSpec = new SpecificSegmentSpec(segmentDescriptor); return new SpecificSegmentQueryRunner( - new MetricsEmittingQueryRunner( - emitter, - new Function, ServiceMetricEvent.Builder>() - { - @Override - public ServiceMetricEvent.Builder apply(@Nullable final Query input) - { - return toolChest.makeMetricBuilder(input); - } - }, - new BySegmentQueryRunner( + new BySegmentQueryRunner( + adapter.getIdentifier(), + adapter.getDataInterval().getStart(), + new CachingQueryRunner( adapter.getIdentifier(), - adapter.getDataInterval().getStart(), - new CachingQueryRunner( - adapter.getIdentifier(), - segmentDescriptor, - objectMapper, - cache, - toolChest, - new ReferenceCountingSegmentQueryRunner(factory, adapter), - cacheConfig - ) + segmentDescriptor, + objectMapper, + cache, + toolChest, + new MetricsEmittingQueryRunner( + emitter, + new Function, ServiceMetricEvent.Builder>() + { + @Override + public ServiceMetricEvent.Builder apply(@Nullable final Query input) + { + return toolChest.makeMetricBuilder(input); + } + }, + new ReferenceCountingSegmentQueryRunner(factory, adapter) + ).withWaitMeasuredFromNow(), + cacheConfig ) - ).withWaitMeasuredFromNow(), + ), segmentSpec ); }