diff --git a/server/src/main/java/org/apache/druid/client/BatchServerInventoryView.java b/server/src/main/java/org/apache/druid/client/BatchServerInventoryView.java index 09292566762..d3b254f192a 100644 --- a/server/src/main/java/org/apache/druid/client/BatchServerInventoryView.java +++ b/server/src/main/java/org/apache/druid/client/BatchServerInventoryView.java @@ -124,7 +124,7 @@ public class BatchServerInventoryView extends AbstractCuratorServerInventoryView Pair input ) { - return input.rhs; + return DataSegmentInterner.intern(input.rhs); } } )); diff --git a/server/src/main/java/org/apache/druid/client/HttpServerInventoryView.java b/server/src/main/java/org/apache/druid/client/HttpServerInventoryView.java index d5be096f79b..edb95c00002 100644 --- a/server/src/main/java/org/apache/druid/client/HttpServerInventoryView.java +++ b/server/src/main/java/org/apache/druid/client/HttpServerInventoryView.java @@ -586,18 +586,19 @@ public class HttpServerInventoryView implements ServerInventoryView, FilteredSer }; } - private void addSegment(final DataSegment segment) + private void addSegment(DataSegment segment) { if (finalPredicate.apply(Pair.of(druidServer.getMetadata(), segment))) { if (druidServer.getSegment(segment.getId()) == null) { - druidServer.addDataSegment(segment); + DataSegment theSegment = DataSegmentInterner.intern(segment); + druidServer.addDataSegment(theSegment); runSegmentCallbacks( new Function() { @Override public CallbackAction apply(SegmentCallback input) { - return input.segmentAdded(druidServer.getMetadata(), segment); + return input.segmentAdded(druidServer.getMetadata(), theSegment); } } ); diff --git a/server/src/main/java/org/apache/druid/client/SingleServerInventoryView.java b/server/src/main/java/org/apache/druid/client/SingleServerInventoryView.java index 7c4d7b1af55..a7a46308fcd 100644 --- a/server/src/main/java/org/apache/druid/client/SingleServerInventoryView.java +++ b/server/src/main/java/org/apache/druid/client/SingleServerInventoryView.java @@ -81,7 +81,7 @@ public class SingleServerInventoryView extends AbstractCuratorServerInventoryVie Predicates.or(segmentPredicates.values()) ); if (predicate.apply(Pair.of(container.getMetadata(), inventory))) { - addSingleInventory(container, inventory); + addSingleInventory(container, DataSegmentInterner.intern(inventory)); } return container; }