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()