skip file with invalid format

2 months ago · 62ed2366f3
1 changed files with 4 additions and 0 deletions
--- 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)