diff --git a/internal/datanode/meta_service.go b/internal/datanode/meta_service.go index 9d015de720..22eac52d52 100644 --- a/internal/datanode/meta_service.go +++ b/internal/datanode/meta_service.go @@ -55,8 +55,8 @@ func (mService *metaService) getCollectionSchema(ctx context.Context, collID Uni } response, err := mService.rootCoord.DescribeCollection(ctx, req) - if response.Status.ErrorCode != commonpb.ErrorCode_Success { - return nil, fmt.Errorf("Describe collection %v from rootcoord wrong: %s", collID, err.Error()) + if response.GetStatus().GetErrorCode() != commonpb.ErrorCode_Success { + return nil, fmt.Errorf("Describe collection %v from rootcoord wrong: %s", collID, response.GetStatus().GetReason()) } if err != nil { diff --git a/internal/storage/local_chunk_manager.go b/internal/storage/local_chunk_manager.go index 11add30031..eb61db0075 100644 --- a/internal/storage/local_chunk_manager.go +++ b/internal/storage/local_chunk_manager.go @@ -18,6 +18,8 @@ import ( "path" "golang.org/x/exp/mmap" + + "github.com/milvus-io/milvus/internal/log" ) type LocalChunkManager struct { @@ -80,7 +82,14 @@ func (lcm *LocalChunkManager) Read(key string) ([]byte, error) { func (lcm *LocalChunkManager) ReadAt(key string, p []byte, off int64) (n int, err error) { path := path.Join(lcm.localPath, key) at, err := mmap.Open(path) - defer at.Close() + defer func() { + if at != nil { + err = at.Close() + if err != nil { + log.Error(err.Error()) + } + } + }() if err != nil { return 0, err }