fix table sampling

apache · Oct 12, 2023 · c2bbaa6 · c2bbaa6
1 parent 1fb88a3
commit c2bbaa6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/server/src/main/java/org/apache/druid/client/CachingClusteredClient.java b/server/src/main/java/org/apache/druid/client/CachingClusteredClient.java
@@ -519,7 +519,7 @@ private Pair<Integer, Integer> pruneSegmentsForShardSampling(final Set<SegmentSe
           int allShards = segments.stream()
               .mapToInt(s -> s.getSegmentDescriptor().getPartitionNumber()).max().getAsInt();
           int targetShards = Math.round(
-              allShards * ((SampledTableDataSource) query.getDataSource()).getSamplingPercentage());
+              allShards * ((SampledTableDataSource) query.getDataSource()).getSamplingPercentage()) / 100;
           Iterator<SegmentServerSelector> iterator = segments.iterator();
           int removedSegments = 0;
           while (iterator.hasNext()) {