未验证 提交 1a0449f4 编写于 作者: J Jiquan Long 提交者: GitHub

Refine log of ReleaseCollection (#13450)

Signed-off-by: Ndragondriver <jiquan.long@zilliz.com>
上级 42ac5f76
......@@ -480,14 +480,18 @@ func (node *Proxy) ReleaseCollection(ctx context.Context, request *milvuspb.Rele
chMgr: node.chMgr,
}
log.Debug("ReleaseCollection received",
method := "ReleaseCollection"
log.Debug(
rpcReceived(method),
zap.String("traceID", traceID),
zap.String("role", typeutil.ProxyRole),
zap.String("db", request.DbName),
zap.String("collection", request.CollectionName))
if err := node.sched.ddQueue.Enqueue(rct); err != nil {
log.Debug("ReleaseCollection failed to enqueue",
log.Warn(
rpcFailedToEnqueue(method),
zap.Error(err),
zap.String("traceID", traceID),
zap.String("role", typeutil.ProxyRole),
......@@ -500,7 +504,8 @@ func (node *Proxy) ReleaseCollection(ctx context.Context, request *milvuspb.Rele
}, nil
}
log.Debug("ReleaseCollection enqueued",
log.Debug(
rpcEnqueued(method),
zap.String("traceID", traceID),
zap.String("role", typeutil.ProxyRole),
zap.Int64("MsgID", rct.ID()),
......@@ -510,7 +515,8 @@ func (node *Proxy) ReleaseCollection(ctx context.Context, request *milvuspb.Rele
zap.String("collection", request.CollectionName))
if err := rct.WaitToFinish(); err != nil {
log.Debug("ReleaseCollection failed to WaitToFinish",
log.Warn(
rpcFailedToWaitToFinish(method),
zap.Error(err),
zap.String("traceID", traceID),
zap.String("role", typeutil.ProxyRole),
......@@ -526,7 +532,8 @@ func (node *Proxy) ReleaseCollection(ctx context.Context, request *milvuspb.Rele
}, nil
}
log.Debug("ReleaseCollection done",
log.Debug(
rpcDone(method),
zap.String("traceID", traceID),
zap.String("role", typeutil.ProxyRole),
zap.Int64("MsgID", rct.ID()),
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册