diff options
author | zalyalov <zalyalov@yandex-team.com> | 2023-10-06 12:59:15 +0300 |
---|---|---|
committer | zalyalov <zalyalov@yandex-team.com> | 2023-10-06 13:34:35 +0300 |
commit | 7775f59248540408cbd58e95b8b3a285fcf51e2d (patch) | |
tree | c50ccdc44d5271bd70749ecedbaf1fd62b37cbbc | |
parent | 76e860bc8191aa0bde14d3d8096e725a6a75dc5d (diff) | |
download | ydb-7775f59248540408cbd58e95b8b3a285fcf51e2d.tar.gz |
disable balancing in test_hive_drain to fix flaky behaviour
-rw-r--r-- | ydb/tests/functional/hive/test_drain.py | 10 | ||||
-rw-r--r-- | ydb/tests/library/harness/kikimr_config.py | 4 |
2 files changed, 12 insertions, 2 deletions
diff --git a/ydb/tests/functional/hive/test_drain.py b/ydb/tests/functional/hive/test_drain.py index 3798ec28ea4..305aea9f59c 100644 --- a/ydb/tests/functional/hive/test_drain.py +++ b/ydb/tests/functional/hive/test_drain.py @@ -21,9 +21,15 @@ class TestHive(object): def setup_class(cls): cls.cluster = kikimr_cluster_factory( KikimrConfigGenerator( - Erasure.BLOCK_4_2, additional_log_configs={ + Erasure.BLOCK_4_2, + additional_log_configs={ 'HIVE': LogLevels.TRACE, 'LOCAL': LogLevels.TRACE - } + }, + hive_config={ + 'max_node_usage_to_kick': 100, + 'min_scatter_to_balance': 100, + 'object_imbalance_to_balance': 1000000, + }, ) ) cls.cluster.start() diff --git a/ydb/tests/library/harness/kikimr_config.py b/ydb/tests/library/harness/kikimr_config.py index 27b7b10efd1..85e9f2ecb77 100644 --- a/ydb/tests/library/harness/kikimr_config.py +++ b/ydb/tests/library/harness/kikimr_config.py @@ -147,6 +147,7 @@ class KikimrConfigGenerator(object): default_users=None, # dict[user]=password extra_feature_flags=None, # list[str] extra_grpc_services=None, # list[str] + hive_config=None, ): if extra_feature_flags is None: extra_feature_flags = [] @@ -328,6 +329,9 @@ class KikimrConfigGenerator(object): elif public_http_config_path: self.yaml_config["public_http_config"] = _load_yaml_config(public_http_config_path) + if hive_config: + self.yaml_config["hive_config"] = hive_config + self.__build() if self.grpc_ssl_enable: |