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

fix: error message when input is not aligned (#35322) (#35324) 

fix: https://github.com/milvus-io/milvus/issues/35321
pr: https://github.com/milvus-io/milvus/pull/35322

Signed-off-by: longjiquan <jiquan.long@zilliz.com>
pull/35320/head
Jiquan Long 2024-08-07 14:32:22 +08:00 committed by GitHub
parent 52fcd3f48b
commit 6027647c00
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
internal/proxy/validate_util.go
View File

@ -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 { func (v *validateUtil) checkAligned(data []*schemapb.FieldData, schema *typeutil.SchemaHelper, numRows uint64) error {
errNumRowsMismatch := func(fieldName string, fieldNumRows, passedNumRows uint64) error { 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, passedNumRows) msg := fmt.Sprintf("the num_rows (%d) of field (%s) is not equal to passed num_rows (%d)", fieldNumRows, fieldName, numRows)
return merr.WrapErrParameterInvalid(passedNumRows, numRows, msg) return merr.WrapErrParameterInvalid(numRows, fieldNumRows, msg)
} }
errDimMismatch := func(fieldName string, dataDim int64, schemaDim int64) error { 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) 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 { if n != numRows {
return errNumRowsMismatch(field.GetFieldName(), n, numRows) return errNumRowsMismatch(field.GetFieldName(), n)
} }
case schemapb.DataType_BinaryVector: case schemapb.DataType_BinaryVector:
@ -178,7 +178,7 @@ func (v *validateUtil) checkAligned(data []*schemapb.FieldData, schema *typeutil
} }
if n != numRows { if n != numRows {
return errNumRowsMismatch(field.GetFieldName(), n, numRows) return errNumRowsMismatch(field.GetFieldName(), n)
} }
default: default:
@ -189,7 +189,7 @@ func (v *validateUtil) checkAligned(data []*schemapb.FieldData, schema *typeutil
} }
if n != numRows { if n != numRows {
return errNumRowsMismatch(field.GetFieldName(), n, numRows) return errNumRowsMismatch(field.GetFieldName(), n)
} }
} }
} }