This is an automated email from the ASF dual-hosted git repository. xiangfu pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push: new 2babb6fb5e Don't log segment name in TimeSegmentPruner (#14855) 2babb6fb5e is described below commit 2babb6fb5e4d5d6b34cdca2421ab0d797d35580a Author: Xiang Fu <xiangfu.1...@gmail.com> AuthorDate: Wed Jan 22 07:01:00 2025 +0800 Don't log segment name in TimeSegmentPruner (#14855) --- .../apache/pinot/broker/routing/segmentpruner/TimeSegmentPruner.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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 59aa65406d..b4ed517192 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 @@ public class TimeSegmentPruner implements SegmentPruner { 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; } --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org For additional commands, e-mail: commits-h...@pinot.apache.org