diff --git a/server/src/main/java/org/apache/druid/server/coordinator/DruidCoordinator.java b/server/src/main/java/org/apache/druid/server/coordinator/DruidCoordinator.java index 2b6e8c271dff..8414e50e1f1f 100644 --- a/server/src/main/java/org/apache/druid/server/coordinator/DruidCoordinator.java +++ b/server/src/main/java/org/apache/druid/server/coordinator/DruidCoordinator.java @@ -522,7 +522,7 @@ public int getCachedBalancerThreadNumber() { return cachedBalancerThreadNumber; } - + @VisibleForTesting public ListeningExecutorService getBalancerExec() { diff --git a/server/src/main/java/org/apache/druid/server/coordinator/duty/LogUsedSegments.java b/server/src/main/java/org/apache/druid/server/coordinator/duty/LogUsedSegments.java index 03c814d944d6..3904db9ecd57 100644 --- a/server/src/main/java/org/apache/druid/server/coordinator/duty/LogUsedSegments.java +++ b/server/src/main/java/org/apache/druid/server/coordinator/duty/LogUsedSegments.java @@ -37,17 +37,9 @@ public DruidCoordinatorRuntimeParams run(DruidCoordinatorRuntimeParams params) { log.debug("Starting coordination. Getting used segments."); - DataSourcesSnapshot dataSourcesSnapshot = params.getDataSourcesSnapshot(); - for (DataSegment segment : dataSourcesSnapshot.iterateAllUsedSegmentsInSnapshot()) { - if (segment.getSize() < 0) { - log.makeAlert("No size on a segment") - .addData("segment", segment) - .emit(); - } - } - - // Log info about all used segments + // Log info about all used segments only if debug logging is enabled if (log.isDebugEnabled()) { + DataSourcesSnapshot dataSourcesSnapshot = params.getDataSourcesSnapshot(); log.debug("Used Segments"); for (DataSegment dataSegment : dataSourcesSnapshot.iterateAllUsedSegmentsInSnapshot()) { log.debug(" %s", dataSegment);