From b1992e84cc335d27f4671c8a5ec209a9acf70b9d Mon Sep 17 00:00:00 2001 From: smellthemoon <64083300+smellthemoon@users.noreply.github.com> Date: Wed, 29 Mar 2023 10:06:01 +0800 Subject: [PATCH] Delete dup check (#23076) Signed-off-by: lixinguo Co-authored-by: lixinguo --- internal/proxy/task_insert.go | 7 ------- internal/proxy/task_upsert.go | 7 ------- 2 files changed, 14 deletions(-) diff --git a/internal/proxy/task_insert.go b/internal/proxy/task_insert.go index 5f7ca408f7..3119f4aba0 100644 --- a/internal/proxy/task_insert.go +++ b/internal/proxy/task_insert.go @@ -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 } diff --git a/internal/proxy/task_upsert.go b/internal/proxy/task_upsert.go index d341cdd91f..a132c82bde 100644 --- a/internal/proxy/task_upsert.go +++ b/internal/proxy/task_upsert.go @@ -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