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