Improve concurrency between DruidSchema and BrokerServerView (apache#…

…11457) * Improve concurrency between DruidSchema and BrokerServerView * unused imports and workaround for error prone faiure * count only known segments * add comments
xvrl · Aug 6, 2021 · e9d964d · e9d964d
1 parent 39a3db7
commit e9d964d
Show file tree

Hide file tree

Showing 5 changed files with 1,515 additions and 345 deletions.
diff --git a/server/src/main/java/org/apache/druid/client/SingleServerInventoryView.java b/server/src/main/java/org/apache/druid/client/SingleServerInventoryView.java
@@ -120,13 +120,13 @@ protected void segmentCallbackRemoved(SegmentCallback callback)
     segmentPredicates.remove(callback);
   }
 
-  static class FilteringSegmentCallback implements SegmentCallback
+  public static class FilteringSegmentCallback implements SegmentCallback
   {
 
     private final SegmentCallback callback;
     private final Predicate<Pair<DruidServerMetadata, DataSegment>> filter;
 
-    FilteringSegmentCallback(SegmentCallback callback, Predicate<Pair<DruidServerMetadata, DataSegment>> filter)
+    public FilteringSegmentCallback(SegmentCallback callback, Predicate<Pair<DruidServerMetadata, DataSegment>> filter)
     {
       this.callback = callback;
       this.filter = filter;