update shards

Signed-off-by: zhuwenxing <wenxing.zhu@zilliz.com>
2025-04-01 14:55:35 +08:00 · 2025-04-01 14:55:35 +08:00 · ea20ed80bf
parent 4d36ae208a
commit ea20ed80bf
1 changed files with 1 additions and 1 deletions
--- a/tests/python_client/cdc/perf/milvus_cdc_recovery_perf_test.py
+++ b/tests/python_client/cdc/perf/milvus_cdc_recovery_perf_test.py
@ -276,7 +276,7 @@ class MilvusCDCPerformance:
        schema = CollectionSchema(fields, "Milvus CDC test collection")
        c_name = "milvus_cdc_perf_test" + datetime.now().strftime("%Y%m%d%H%M%S")
        # Create collections
-        self.source_collection = Collection(c_name, schema, using=self.source_alias, num_shards=2)
+        self.source_collection = Collection(c_name, schema, using=self.source_alias, num_shards=4)
        time.sleep(5)
        self.target_collection = Collection(c_name, using=self.target_alias)
        index_params = {