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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
