diff --git a/internal/proxynode/impl.go b/internal/proxynode/impl.go index cb014501e22956e9b8f7230ef91816c1954489bc..6b248738adb672799e1d00ad5aaddf4ec563fef1 100644 --- a/internal/proxynode/impl.go +++ b/internal/proxynode/impl.go @@ -25,7 +25,12 @@ func (node *NodeImpl) UpdateStateCode(code internalpb2.StateCode) { } func (node *NodeImpl) InvalidateCollectionMetaCache(ctx context.Context, request *proxypb.InvalidateCollMetaCacheRequest) (*commonpb.Status, error) { - panic("implement me") + collectionName := request.CollectionName + _ = globalMetaCache.Remove(collectionName) // no need to return error, though collection may be not cached + return &commonpb.Status{ + ErrorCode: commonpb.ErrorCode_SUCCESS, + Reason: "", + }, nil } func (node *NodeImpl) CreateCollection(request *milvuspb.CreateCollectionRequest) (*commonpb.Status, error) {