mirror of https://github.com/milvus-io/milvus.git
Delete dup check (#23076)
Signed-off-by: lixinguo <xinguo.li@zilliz.com> Co-authored-by: lixinguo <xinguo.li@zilliz.com>pull/22942/head
parent
dc6d4b913a
commit
b1992e84cc
|
@ -160,13 +160,6 @@ func (it *insertTask) PreExecute(ctx context.Context) error {
|
|||
return err
|
||||
}
|
||||
|
||||
// check that all field's number rows are equal
|
||||
if err = it.insertMsg.CheckAligned(); err != nil {
|
||||
log.Error("field data is not aligned",
|
||||
zap.Error(err))
|
||||
return err
|
||||
}
|
||||
|
||||
if err := newValidateUtil(withNANCheck()).Validate(it.insertMsg.GetFieldsData(), schema, it.insertMsg.NRows()); err != nil {
|
||||
return err
|
||||
}
|
||||
|
|
|
@ -185,13 +185,6 @@ func (it *upsertTask) insertPreExecute(ctx context.Context) error {
|
|||
return err
|
||||
}
|
||||
|
||||
// check that all field's number rows are equal
|
||||
if err = it.upsertMsg.InsertMsg.CheckAligned(); err != nil {
|
||||
log.Error("field data is not aligned when upsert",
|
||||
zap.Error(err))
|
||||
return err
|
||||
}
|
||||
|
||||
if err := newValidateUtil(withNANCheck()).
|
||||
Validate(it.upsertMsg.InsertMsg.GetFieldsData(), it.schema, it.upsertMsg.InsertMsg.NRows()); err != nil {
|
||||
return err
|
||||
|
|
Loading…
Reference in New Issue