diff --git a/tests/integration/import/auto_id_test.go b/tests/integration/import/auto_id_test.go index 3673ce0187..d907c71d7f 100644 --- a/tests/integration/import/auto_id_test.go +++ b/tests/integration/import/auto_id_test.go @@ -47,7 +47,7 @@ func (s *BulkInsertSuite) runTestAutoID() { ctx, cancel := context.WithTimeout(c.GetContext(), 240*time.Second) defer cancel() - collectionName := "TestBulkInsert" + funcutil.GenRandomStr() + collectionName := "TestBulkInsert" + funcutil.RandomString(8) var schema *schemapb.CollectionSchema fieldSchema1 := &schemapb.FieldSchema{FieldID: 100, Name: "id", DataType: s.pkType, TypeParams: []*commonpb.KeyValuePair{{Key: common.MaxLengthKey, Value: "128"}}, IsPrimaryKey: true, AutoID: true} diff --git a/tests/integration/import/binlog_test.go b/tests/integration/import/binlog_test.go index cc3bb250e5..7dd398244c 100644 --- a/tests/integration/import/binlog_test.go +++ b/tests/integration/import/binlog_test.go @@ -62,7 +62,7 @@ func (s *BulkInsertSuite) PrepareSourceCollection(dim int, dmlGroup *DMLGroup) * defer cancel() c := s.Cluster - collectionName := "TestBinlogImport_A_" + funcutil.GenRandomStr() + collectionName := "TestBinlogImport_A_" + funcutil.RandomString(8) schema := integration.ConstructSchemaOfVecDataTypeWithStruct(collectionName, dim, true) marshaledSchema, err := proto.Marshal(schema) @@ -297,7 +297,7 @@ func (s *BulkInsertSuite) runBinlogTest(dmlGroup *DMLGroup) { return num }) - collectionName := "TestBinlogImport_B_" + funcutil.GenRandomStr() + collectionName := "TestBinlogImport_B_" + funcutil.RandomString(8) schema := integration.ConstructSchema(collectionName, dim, true) marshaledSchema, err := proto.Marshal(schema) @@ -482,7 +482,7 @@ func (s *BulkInsertSuite) TestInvalidInput() { c := s.Cluster ctx := c.GetContext() - collectionName := "TestBinlogImport_InvalidInput_" + funcutil.GenRandomStr() + collectionName := "TestBinlogImport_InvalidInput_" + funcutil.RandomString(8) schema := integration.ConstructSchema(collectionName, dim, true) marshaledSchema, err := proto.Marshal(schema) s.NoError(err) diff --git a/tests/integration/import/dynamic_field_test.go b/tests/integration/import/dynamic_field_test.go index ce02c931ed..873b4772a1 100644 --- a/tests/integration/import/dynamic_field_test.go +++ b/tests/integration/import/dynamic_field_test.go @@ -48,7 +48,7 @@ func (s *BulkInsertSuite) testImportDynamicField() { ctx, cancel := context.WithTimeout(c.GetContext(), 240*time.Second) defer cancel() - collectionName := "TestBulkInsert_B_" + funcutil.GenRandomStr() + collectionName := "TestBulkInsert_B_" + funcutil.RandomString(8) schema := integration.ConstructSchema(collectionName, dim, true, &schemapb.FieldSchema{ FieldID: 100, diff --git a/tests/integration/import/import_test.go b/tests/integration/import/import_test.go index a72f6a6265..36014c3588 100644 --- a/tests/integration/import/import_test.go +++ b/tests/integration/import/import_test.go @@ -81,7 +81,7 @@ func (s *BulkInsertSuite) run() { ctx, cancel := context.WithTimeout(c.GetContext(), 240*time.Second) defer cancel() - collectionName := "TestBulkInsert" + funcutil.GenRandomStr() + collectionName := "TestBulkInsert" + funcutil.RandomString(8) var schema *schemapb.CollectionSchema fieldSchema1 := &schemapb.FieldSchema{FieldID: 100, Name: "id", DataType: s.pkType, TypeParams: []*commonpb.KeyValuePair{{Key: common.MaxLengthKey, Value: "128"}}, IsPrimaryKey: true, AutoID: false} @@ -288,7 +288,7 @@ func (s *BulkInsertSuite) TestZeroRowCount() { ctx, cancel := context.WithTimeout(c.GetContext(), 60*time.Second) defer cancel() - collectionName := "TestBulkInsert_" + funcutil.GenRandomStr() + collectionName := "TestBulkInsert_" + funcutil.RandomString(8) schema := integration.ConstructSchema(collectionName, dim, true, &schemapb.FieldSchema{FieldID: 100, Name: "id", DataType: schemapb.DataType_Int64, IsPrimaryKey: true, AutoID: true}, diff --git a/tests/integration/import/multi_vector_test.go b/tests/integration/import/multi_vector_test.go index e38e9a9cb3..db852bd114 100644 --- a/tests/integration/import/multi_vector_test.go +++ b/tests/integration/import/multi_vector_test.go @@ -50,7 +50,7 @@ func (s *BulkInsertSuite) testMultipleVectorFields() { ctx, cancel := context.WithTimeout(c.GetContext(), 600*time.Second) defer cancel() - collectionName := "TestBulkInsert_MultipleVectorFields_" + funcutil.GenRandomStr() + collectionName := "TestBulkInsert_MultipleVectorFields_" + funcutil.RandomString(8) schema := integration.ConstructSchema(collectionName, 0, true, &schemapb.FieldSchema{ FieldID: 100, diff --git a/tests/integration/import/partition_key_test.go b/tests/integration/import/partition_key_test.go index d7e3a15cbb..9029fb3f37 100644 --- a/tests/integration/import/partition_key_test.go +++ b/tests/integration/import/partition_key_test.go @@ -48,7 +48,7 @@ func (s *BulkInsertSuite) TestImportWithPartitionKey() { ctx, cancel := context.WithTimeout(c.GetContext(), 240*time.Second) defer cancel() - collectionName := "TestBulkInsert_WithPartitionKey_" + funcutil.GenRandomStr() + collectionName := "TestBulkInsert_WithPartitionKey_" + funcutil.RandomString(8) schema := integration.ConstructSchema(collectionName, dim, true, &schemapb.FieldSchema{ FieldID: 100, @@ -218,7 +218,7 @@ func (s *BulkInsertSuite) TestImportWithAFewRows() { ctx, cancel := context.WithTimeout(c.GetContext(), 240*time.Second) defer cancel() - collectionName := "TestBulkInsert_WithPartitionKey_" + funcutil.GenRandomStr() + collectionName := "TestBulkInsert_WithPartitionKey_" + funcutil.RandomString(8) schema := integration.ConstructSchema(collectionName, dim, true, &schemapb.FieldSchema{ FieldID: 100, diff --git a/tests/integration/import/vector_array_test.go b/tests/integration/import/vector_array_test.go index f25ba6bb13..c987af8271 100644 --- a/tests/integration/import/vector_array_test.go +++ b/tests/integration/import/vector_array_test.go @@ -47,7 +47,7 @@ func TestGenerateJsonFileWithVectorArray(t *testing.T) { maxArrayCapacity = 10 ) - collectionName := "TestBulkInsert_VectorArray_" + funcutil.GenRandomStr() + collectionName := "TestBulkInsert_VectorArray_" + funcutil.RandomString(8) // Create schema with StructArrayField containing vector array schema := integration.ConstructSchema(collectionName, 0, true, &schemapb.FieldSchema{ @@ -127,7 +127,7 @@ func (s *BulkInsertSuite) runForStructArray() { ctx, cancel := context.WithTimeout(c.GetContext(), 600*time.Second) defer cancel() - collectionName := "TestBulkInsert_VectorArray_" + funcutil.GenRandomStr() + collectionName := "TestBulkInsert_VectorArray_" + funcutil.RandomString(8) // Create schema with StructArrayField containing vector array schema := integration.ConstructSchema(collectionName, 0, true, &schemapb.FieldSchema{