diff options
| author | chrislu <chris.lu@gmail.com> | 2025-08-15 10:19:31 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2025-08-15 10:35:33 -0700 |
| commit | 62ed2366f33083a46c40eb1183d2927994ec0203 (patch) | |
| tree | 702f9e8020709d490e967dd7fd2a9f1270cd0d3a | |
| parent | 8eb85415fb24adaa467534d8cdf907a7bf57e921 (diff) | |
| download | seaweedfs-62ed2366f33083a46c40eb1183d2927994ec0203.tar.xz seaweedfs-62ed2366f33083a46c40eb1183d2927994ec0203.zip | |
skip file with invalid format
| -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) |