milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Print err info when insert msg not aligned (#16305) 

Signed-off-by: xige-16 <xi.ge@zilliz.com>
pull/17047/head
xige-16 2022-05-17 13:01:57 +08:00 committed by GitHub
parent 960d35e517
commit c2f1d65fa1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
internal/querynode/flow_graph_insert_node.go
View File

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