You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@skywalking.apache.org by ha...@apache.org on 2022/03/07 01:51:33 UTC
[skywalking-banyandb] 01/01: Add a prefix to the root path
This is an automated email from the ASF dual-hosted git repository.
hanahmily pushed a commit to branch bug-path
in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb.git
commit d127111ff2933097e44ae16da0051dc50554b889
Author: Gao Hongtao <ha...@gmail.com>
AuthorDate: Mon Mar 7 01:50:37 2022 +0000
Add a prefix to the root path
Signed-off-by: Gao Hongtao <ha...@gmail.com>
---
banyand/measure/service.go | 3 ++-
banyand/stream/service.go | 3 ++-
2 files changed, 4 insertions(+), 2 deletions(-)
diff --git a/banyand/measure/service.go b/banyand/measure/service.go
index 0181409..78d5252 100644
--- a/banyand/measure/service.go
+++ b/banyand/measure/service.go
@@ -19,6 +19,7 @@ package measure
import (
"context"
+ "path"
"time"
"github.com/pkg/errors"
@@ -96,7 +97,7 @@ func (s *service) PreRun() error {
if err != nil {
return err
}
- s.schemaRepo = newSchemaRepo(s.root, s.metadata, s.repo, s.l)
+ s.schemaRepo = newSchemaRepo(path.Join(s.root, s.Name()), s.metadata, s.repo, s.l)
for _, g := range groups {
if g.Catalog != commonv1.Catalog_CATALOG_MEASURE {
continue
diff --git a/banyand/stream/service.go b/banyand/stream/service.go
index eab1f34..bb9dc70 100644
--- a/banyand/stream/service.go
+++ b/banyand/stream/service.go
@@ -19,6 +19,7 @@ package stream
import (
"context"
+ "path"
"time"
"github.com/pkg/errors"
@@ -92,7 +93,7 @@ func (s *service) PreRun() error {
if err != nil {
return err
}
- s.schemaRepo = newSchemaRepo(s.root, s.metadata, s.repo, s.l)
+ s.schemaRepo = newSchemaRepo(path.Join(s.root, s.Name()), s.metadata, s.repo, s.l)
for _, g := range groups {
if g.Catalog != commonv1.Catalog_CATALOG_STREAM {
continue