From 42be531f9cf8a3a17002c565d6f585e5dbb493a9 Mon Sep 17 00:00:00 2001 From: "zhenshan.cao" Date: Sat, 26 Jun 2021 14:02:12 +0800 Subject: [PATCH] Add InsertCnt (#6131) * Add InsertCnt Signed-off-by: zhenshan.cao * Enhance log Signed-off-by: zhenshan.cao --- internal/proxy/impl.go | 1 + internal/rootcoord/root_coord.go | 4 +++- 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/internal/proxy/impl.go b/internal/proxy/impl.go index f48fef92a6..ab773aede3 100644 --- a/internal/proxy/impl.go +++ b/internal/proxy/impl.go @@ -1241,6 +1241,7 @@ func (node *Proxy) Insert(ctx context.Context, request *milvuspb.InsertRequest) } it.result.ErrIndex = errIndex } + it.result.InsertCnt = int64(it.req.NumRows) return it.result, nil } diff --git a/internal/rootcoord/root_coord.go b/internal/rootcoord/root_coord.go index 69dda1a510..b2cfe58790 100644 --- a/internal/rootcoord/root_coord.go +++ b/internal/rootcoord/root_coord.go @@ -1602,7 +1602,9 @@ func (c *Core) CreateIndex(ctx context.Context, in *milvuspb.CreateIndexRequest) } err := executeTask(t) if err != nil { - log.Debug("CreateIndex Failed", zap.String("collection name", in.CollectionName), zap.String("field name", in.FieldName), zap.Int64("msgID", in.Base.MsgID)) + log.Debug("CreateIndex Failed", zap.String("collection name", in.CollectionName), + zap.String("field name", in.FieldName), zap.Int64("msgID", in.Base.MsgID), + zap.Error(err)) return &commonpb.Status{ ErrorCode: commonpb.ErrorCode_UnexpectedError, Reason: "CreateIndex failed, error = " + err.Error(),