From c2f1d65fa1d26012a18e4f78f9de5b52cdbeeb89 Mon Sep 17 00:00:00 2001 From: xige-16 Date: Tue, 17 May 2022 13:01:57 +0800 Subject: [PATCH] Print err info when insert msg not aligned (#16305) Signed-off-by: xige-16 --- internal/querynode/flow_graph_insert_node.go | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/internal/querynode/flow_graph_insert_node.go b/internal/querynode/flow_graph_insert_node.go index 8e7b84cc57..e720484ca0 100644 --- a/internal/querynode/flow_graph_insert_node.go +++ b/internal/querynode/flow_graph_insert_node.go @@ -19,7 +19,6 @@ package querynode import ( "bytes" "encoding/binary" - "errors" "fmt" "io" "reflect" @@ -369,8 +368,8 @@ func (iNode *insertNode) delete(deleteData *deleteData, segmentID UniqueID, wg * // getPrimaryKeys would get primary keys by insert messages func getPrimaryKeys(msg *msgstream.InsertMsg, streamingReplica ReplicaInterface) ([]primaryKey, error) { if err := msg.CheckAligned(); err != nil { - log.Warn("misaligned messages detected") - return nil, errors.New("misaligned messages detected") + log.Warn("misaligned messages detected", zap.Error(err)) + return nil, err } collectionID := msg.GetCollectionID()