diff --git a/internal/datacoord/server.go b/internal/datacoord/server.go index 64ded38bf3..16fde525b5 100644 --- a/internal/datacoord/server.go +++ b/internal/datacoord/server.go @@ -418,7 +418,9 @@ func (s *Server) initGarbageCollection(cli storage.ChunkManager) { dropTolerance: Params.DataCoordCfg.GCDropTolerance, collValidator: func(collID int64) bool { resp, err := s.rootCoordClient.DescribeCollectionInternal(context.Background(), &milvuspb.DescribeCollectionRequest{ - Base: commonpbutil.NewMsgBase(), + Base: commonpbutil.NewMsgBase( + commonpbutil.WithMsgType(commonpb.MsgType_DescribeCollection), + ), CollectionID: collID, }) if err != nil {