diff --git a/pinot-broker/src/main/java/org/apache/pinot/broker/routing/segmentpruner/TimeSegmentPruner.java b/pinot-broker/src/main/java/org/apache/pinot/broker/routing/segmentpruner/TimeSegmentPruner.java index 59aa65406da8..b4ed517192a4 100644 --- a/pinot-broker/src/main/java/org/apache/pinot/broker/routing/segmentpruner/TimeSegmentPruner.java +++ b/pinot-broker/src/main/java/org/apache/pinot/broker/routing/segmentpruner/TimeSegmentPruner.java @@ -93,10 +93,11 @@ private Interval extractIntervalFromSegmentZKMetaZNRecord(String segment, @Nulla return DEFAULT_INTERVAL; } + // Validate time interval long startTime = znRecord.getLongField(CommonConstants.Segment.START_TIME, -1); long endTime = znRecord.getLongField(CommonConstants.Segment.END_TIME, -1); if (startTime < 0 || endTime < 0 || startTime > endTime) { - LOGGER.warn("Failed to find valid time interval for segment: {}, table: {}", segment, _tableNameWithType); + // Consuming and committing segments don't have time interval return DEFAULT_INTERVAL; }