aboutsummaryrefslogtreecommitdiff
path: root/weed/filer/hbase
diff options
context:
space:
mode:
authorKonstantin Lebedev <lebedev_k@tochka.com>2021-06-15 18:12:39 +0500
committerKonstantin Lebedev <lebedev_k@tochka.com>2021-06-15 18:12:39 +0500
commit6aa1a56ec87ca63f7a072eb6c9599e06fbb5ca9a (patch)
tree2e894d711e7bff2e7e81043f2a00e88c34b685dd /weed/filer/hbase
parentebe971da2e12bc155819ba1e60f720513d0cfc20 (diff)
downloadseaweedfs-6aa1a56ec87ca63f7a072eb6c9599e06fbb5ca9a.tar.xz
seaweedfs-6aa1a56ec87ca63f7a072eb6c9599e06fbb5ca9a.zip
avoid crashes Galera Cluster
https://github.com/chrislusf/seaweedfs/issues/2125
Diffstat (limited to 'weed/filer/hbase')
-rw-r--r--weed/filer/hbase/hbase_store.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/filer/hbase/hbase_store.go b/weed/filer/hbase/hbase_store.go
index e0d878ca7..43c14cc15 100644
--- a/weed/filer/hbase/hbase_store.go
+++ b/weed/filer/hbase/hbase_store.go
@@ -109,7 +109,7 @@ func (store *HbaseStore) DeleteEntry(ctx context.Context, path util.FullPath) (e
return store.doDelete(ctx, store.cfMetaDir, []byte(path))
}
-func (store *HbaseStore) DeleteFolderChildren(ctx context.Context, path util.FullPath) (err error) {
+func (store *HbaseStore) DeleteFolderChildren(ctx context.Context, path util.FullPath, limit int64) (err error) {
family := map[string][]string{store.cfMetaDir: {COLUMN_NAME}}
expectedPrefix := []byte(path.Child(""))