diff --git a/server/src/main/java/org/apache/druid/client/CachingClusteredClient.java b/server/src/main/java/org/apache/druid/client/CachingClusteredClient.java index 9305b1b88e9f..5cb41eb14b17 100644 --- a/server/src/main/java/org/apache/druid/client/CachingClusteredClient.java +++ b/server/src/main/java/org/apache/druid/client/CachingClusteredClient.java @@ -345,6 +345,20 @@ ClusterQueryResult run( } final Set segmentServers = computeSegmentsToQuery(timeline, specificSegments); + if (query.context().isDebug()) { + final String dataSource = ev.getBaseTableDataSource().getName(); + log.infoSegmentIds( + segmentServers.stream().map( + s -> SegmentId.of( + dataSource, + s.getSegmentDescriptor().getInterval(), + s.getSegmentDescriptor().getVersion(), + s.getSegmentDescriptor().getPartitionNumber() + ) + ), + StringUtils.format("Query[%s] found segments from timeline lookup", query.getId()) + ); + } final CloneQueryMode cloneQueryMode = query.context().getCloneQueryMode(); @Nullable final byte[] queryCacheKey = cacheKeyManager.computeSegmentLevelQueryCacheKey();