diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-12-24 00:18:59 -0800 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-12-24 00:18:59 -0800 |
| commit | 9bf6c10505bef2e9f679b203ab2380672d5afb4e (patch) | |
| tree | 7f7e4be3e299dbb0286cdb7c7f685fad0c603d73 | |
| parent | 2fea8cfa0fd56d7f2f459681b727d9625b62bc16 (diff) | |
| download | seaweedfs-9bf6c10505bef2e9f679b203ab2380672d5afb4e.tar.xz seaweedfs-9bf6c10505bef2e9f679b203ab2380672d5afb4e.zip | |
fix prefix
| -rw-r--r-- | weed/filer/hbase/hbase_store.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/filer/hbase/hbase_store.go b/weed/filer/hbase/hbase_store.go index 65cdfd847..03aecfd2b 100644 --- a/weed/filer/hbase/hbase_store.go +++ b/weed/filer/hbase/hbase_store.go @@ -112,7 +112,7 @@ func (store *HbaseStore) DeleteEntry(ctx context.Context, path util.FullPath) (e func (store *HbaseStore) DeleteFolderChildren(ctx context.Context, path util.FullPath) (err error) { family := map[string][]string{store.cfMetaDir: {COLUMN_NAME}} - expectedPrefix := []byte(path + "/") + expectedPrefix := []byte(path.Child("")) scan, err := hrpc.NewScanRange(ctx, store.table, expectedPrefix, nil, hrpc.Families(family)) if err != nil { return err @@ -154,7 +154,7 @@ func (store *HbaseStore) ListDirectoryEntries(ctx context.Context, dirPath util. func (store *HbaseStore) ListDirectoryPrefixedEntries(ctx context.Context, dirPath util.FullPath, startFileName string, includeStartFile bool, limit int, prefix string) ([]*filer.Entry, error) { family := map[string][]string{store.cfMetaDir: {COLUMN_NAME}} - expectedPrefix := []byte(string(dirPath) + "/" + prefix) + expectedPrefix := []byte(dirPath.Child(prefix)) scan, err := hrpc.NewScanRange(ctx, store.table, expectedPrefix, nil, hrpc.Families(family)) if err != nil { return nil, err |