Skip to content

Commit f6f1623

Browse files
authored
Disable annoying logs when segments is empty (#4048)
1 parent f78187a commit f6f1623

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

Diff for: stream/distributedlog/core/src/main/java/org/apache/distributedlog/ReadAheadEntryReader.java

+3
Original file line numberDiff line numberDiff line change
@@ -1014,6 +1014,9 @@ public void onSegmentsUpdated(List<LogSegmentMetadata> segments) {
10141014
if (!started.get()) {
10151015
return;
10161016
}
1017+
if (segments == null || segments.isEmpty()) {
1018+
return;
1019+
}
10171020
logger.info("segments is updated with {}", segments);
10181021
processLogSegments(segments);
10191022
}

0 commit comments

Comments
 (0)