From 62ed2366f33083a46c40eb1183d2927994ec0203 Mon Sep 17 00:00:00 2001 From: chrislu Date: Fri, 15 Aug 2025 10:19:31 -0700 Subject: [PATCH] skip file with invalid format --- weed/filer/filer_notify_read.go | 4 ++++ 1 file changed, 4 insertions(+) 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)