diff options
| -rw-r--r-- | weed/filer/filer_notify_read.go | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/weed/filer/filer_notify_read.go b/weed/filer/filer_notify_read.go index cc24bf9dc..d8b1d38ae 100644 --- a/weed/filer/filer_notify_read.go +++ b/weed/filer/filer_notify_read.go @@ -221,6 +221,10 @@ func (c *LogFileEntryCollector) collectMore(v *OrderedLogVisitor) (err error) { continue } filerId := getFilerId(hourMinuteEntry.Name()) + if filerId == "" { + glog.Warningf("Invalid log file name format: %s", hourMinuteEntry.Name()) + continue // Skip files with invalid format + } iter, found := v.perFilerIteratorMap[filerId] if !found { iter = newLogFileQueueIterator(c.f.MasterClient, util.NewQueue[*LogFileEntry](), c.startTsNs, c.stopTsNs) |