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..978cef166f64 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,14 @@ ClusterQueryResult run( } final Set segmentServers = computeSegmentsToQuery(timeline, specificSegments); + if (query.context().isDebug()) { + log.infoSegmentIds( + segmentServers.stream() + .filter(s -> s.getServer() != null) + .map(s -> s.getServer().getSegment().getId()), + StringUtils.format("Query[%s] found segments from timeline lookup", query.getId()) + ); + } final CloneQueryMode cloneQueryMode = query.context().getCloneQueryMode(); @Nullable final byte[] queryCacheKey = cacheKeyManager.computeSegmentLevelQueryCacheKey();