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

Reply via email to