diff --git a/internal/proxy/validate_util.go b/internal/proxy/validate_util.go index 8a285bf86c..3fe69366fd 100644 --- a/internal/proxy/validate_util.go +++ b/internal/proxy/validate_util.go @@ -123,9 +123,9 @@ func (v *validateUtil) Validate(data []*schemapb.FieldData, schema *schemapb.Col } func (v *validateUtil) checkAligned(data []*schemapb.FieldData, schema *typeutil.SchemaHelper, numRows uint64) error { - errNumRowsMismatch := func(fieldName string, fieldNumRows, passedNumRows uint64) error { - msg := fmt.Sprintf("the num_rows (%d) of field (%s) is not equal to passed num_rows (%d)", fieldNumRows, fieldName, passedNumRows) - return merr.WrapErrParameterInvalid(passedNumRows, numRows, msg) + errNumRowsMismatch := func(fieldName string, fieldNumRows uint64) error { + msg := fmt.Sprintf("the num_rows (%d) of field (%s) is not equal to passed num_rows (%d)", fieldNumRows, fieldName, numRows) + return merr.WrapErrParameterInvalid(numRows, fieldNumRows, msg) } errDimMismatch := func(fieldName string, dataDim int64, schemaDim int64) error { msg := fmt.Sprintf("the dim (%d) of field data(%s) is not equal to schema dim (%d)", dataDim, fieldName, schemaDim) @@ -154,7 +154,7 @@ func (v *validateUtil) checkAligned(data []*schemapb.FieldData, schema *typeutil } if n != numRows { - return errNumRowsMismatch(field.GetFieldName(), n, numRows) + return errNumRowsMismatch(field.GetFieldName(), n) } case schemapb.DataType_BinaryVector: @@ -178,7 +178,7 @@ func (v *validateUtil) checkAligned(data []*schemapb.FieldData, schema *typeutil } if n != numRows { - return errNumRowsMismatch(field.GetFieldName(), n, numRows) + return errNumRowsMismatch(field.GetFieldName(), n) } default: @@ -189,7 +189,7 @@ func (v *validateUtil) checkAligned(data []*schemapb.FieldData, schema *typeutil } if n != numRows { - return errNumRowsMismatch(field.GetFieldName(), n, numRows) + return errNumRowsMismatch(field.GetFieldName(), n) } } }