From 8f660ae4e6795eeb7d6c3e47c1632fd3425fb9df Mon Sep 17 00:00:00 2001 From: sunby Date: Tue, 31 Aug 2021 11:17:59 +0800 Subject: [PATCH] Add log print in proxy (#7369) issue: #7316 Signed-off-by: sunby --- internal/proxy/impl.go | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/internal/proxy/impl.go b/internal/proxy/impl.go index 29c5a7ed1f..24c09f67d5 100644 --- a/internal/proxy/impl.go +++ b/internal/proxy/impl.go @@ -1207,6 +1207,16 @@ func (node *Proxy) Insert(ctx context.Context, request *milvuspb.InsertRequest) } err = node.sched.DmQueue.Enqueue(it) + log.Debug("Insert Task Enqueue", + zap.Int64("msgID", it.BaseInsertTask.InsertRequest.Base.MsgID), + zap.Uint64("timestamp", it.BaseInsertTask.InsertRequest.Base.Timestamp), + zap.String("db", request.DbName), + zap.String("collection", request.CollectionName), + zap.String("partition", request.PartitionName), + zap.Any("len(RowData)", len(it.RowData)), + zap.Any("len(RowIDs)", len(it.RowIDs)), + ) + if err != nil { result.Status.ErrorCode = commonpb.ErrorCode_UnexpectedError result.Status.Reason = err.Error()