From c12fa79f673493e346b0317bc6e8ad27f437e841 Mon Sep 17 00:00:00 2001 From: Roman Tamarov Date: Fri, 21 Nov 2025 11:55:05 +0300 Subject: [PATCH] add scanErr --- weed/filer/hbase/hbase_store.go | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/weed/filer/hbase/hbase_store.go b/weed/filer/hbase/hbase_store.go index d9fd435f5..7663fef9d 100644 --- a/weed/filer/hbase/hbase_store.go +++ b/weed/filer/hbase/hbase_store.go @@ -164,13 +164,12 @@ func (store *HbaseStore) ListDirectoryPrefixedEntries(ctx context.Context, dirPa scanner := store.Client.Scan(scan) defer scanner.Close() for { - res, err := scanner.Next() - if err == io.EOF { - err = nil + res, scanErr := scanner.Next() + if scanErr == io.EOF { break } - if err != nil { - return lastFileName, err + if scanErr != nil { + return lastFileName, scanErr } if len(res.Cells) == 0 { continue