From 2396ac234c060774ef0640f513fee2e424fbb706 Mon Sep 17 00:00:00 2001 From: Chris Lu Date: Tue, 2 Feb 2021 11:34:12 -0800 Subject: [PATCH] filer: fix elastic search pagination possible fix for https://github.com/chrislusf/seaweedfs/issues/1774 --- weed/filer/elastic/v7/elastic_store.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/weed/filer/elastic/v7/elastic_store.go b/weed/filer/elastic/v7/elastic_store.go index 1e7f55599..14719e6ed 100644 --- a/weed/filer/elastic/v7/elastic_store.go +++ b/weed/filer/elastic/v7/elastic_store.go @@ -218,7 +218,6 @@ func (store *ElasticStore) listRootDirectoryEntries(ctx context.Context, startFi if entry, err := store.FindEntry(ctx, weed_util.FullPath("/"+strings.Replace(index.Index, indexPrefix, "", 1))); err == nil { fileName := getFileName(entry.FullPath) - lastFileName = fileName if fileName == startFileName && !inclusive { continue } @@ -229,6 +228,7 @@ func (store *ElasticStore) listRootDirectoryEntries(ctx context.Context, startFi if !eachEntryFunc(entry) { break } + lastFileName = fileName } } } @@ -278,13 +278,13 @@ func (store *ElasticStore) listDirectoryEntries( } nextStart = string(esEntry.Entry.FullPath) fileName := getFileName(esEntry.Entry.FullPath) - lastFileName = fileName if fileName == startFileName && !inclusive { continue } if !eachEntryFunc(esEntry.Entry) { break } + lastFileName = fileName } } }