This is an automated email from the ASF dual-hosted git repository.

hanahmily pushed a commit to branch bug-md
in repository https://gitbox.apache.org/repos/asf/skywalking-banyandb.git

commit 38ec4128bd9df1a209285845eccdd4e1aa90bc81
Author: Gao Hongtao <[email protected]>
AuthorDate: Mon Oct 10 04:10:13 2022 +0000

    Try to create the group if absent
    
    Signed-off-by: Gao Hongtao <[email protected]>
---
 pkg/schema/metadata.go | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/pkg/schema/metadata.go b/pkg/schema/metadata.go
index 90400ec..5f631fc 100644
--- a/pkg/schema/metadata.go
+++ b/pkg/schema/metadata.go
@@ -279,7 +279,10 @@ func (sr *schemaRepo) LoadResource(metadata 
*commonv1.Metadata) (Resource, bool)
 func (sr *schemaRepo) storeResource(metadata *commonv1.Metadata) (Resource, 
error) {
        group, ok := sr.LoadGroup(metadata.Group)
        if !ok {
-               return nil, errors.Errorf("unknown group")
+               var err error
+               if group, err = sr.StoreGroup(&commonv1.Metadata{Name: 
metadata.Group}); err != nil {
+                       return nil, errors.WithMessagef(err, "create unknown 
group:%s", metadata.Group)
+               }
        }
        stm, err := sr.resourceSupplier.ResourceSchema(sr.metadata, metadata)
        if err != nil {

Reply via email to