diff --git a/weed/filer/filer_notify_read.go b/weed/filer/filer_notify_read.go
index d8b1d38ae..af3ce702e 100644
--- a/weed/filer/filer_notify_read.go
+++ b/weed/filer/filer_notify_read.go
@@ -307,6 +307,7 @@ func (iter *LogFileQueueIterator) getNext(v *OrderedLogVisitor) (logEntry *filer
 			if collectErr := v.logFileEntryCollector.collectMore(v); collectErr != nil && collectErr != io.EOF {
 				return nil, collectErr
 			}
+			next = iter.q.Peek() // Re-peek after collectMore
 		}
 		// skip the file if the next entry is before the startTsNs
 		if next != nil && next.TsNs <= iter.startTsNs {