milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Improve error message in rootcoord (#10836) 

Signed-off-by: Xiangyu Wang <xiangyu.wang@zilliz.com>
pull/10852/head
Xiangyu Wang 2021-10-28 20:03:29 +08:00 committed by GitHub
parent aa196e5f7e
commit a7d55229f0
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
internal/rootcoord/dml_channels.go
View File

@ -46,8 +46,8 @@ func newDmlChannels(c *Core, chanNamePrefix string, chanNum int64) *dmlChannels
name := fmt.Sprintf("%s_%d", d.namePrefix, i)
ms, err := c.msFactory.NewMsgStream(c.ctx)
if err != nil {
log.Error("add msgstream failed", zap.String("name", name), zap.Error(err))
panic("add msgstream failed")
log.Error("Failed to add msgstream", zap.String("name", name), zap.Error(err))
panic("Failed to add msgstream")
}
ms.AsProducer([]string{name})
d.pool.Store(name, &ms)