mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-09-20 00:30:49 +00:00
Update test.py
This commit is contained in:
parent
dfdd2ee77c
commit
1308f26ccc
@ -0,0 +1,9 @@
|
|||||||
|
<?xml version="1.0" encoding="utf-8"?>
|
||||||
|
|
||||||
|
<clickhouse>
|
||||||
|
<profiles>
|
||||||
|
<default>
|
||||||
|
<s3_retry_attempts>1000000</s3_retry_attempts>
|
||||||
|
</default>
|
||||||
|
</profiles>
|
||||||
|
</clickhouse>
|
@ -22,6 +22,17 @@ def cluster():
|
|||||||
],
|
],
|
||||||
with_minio=True,
|
with_minio=True,
|
||||||
)
|
)
|
||||||
|
cluster.add_instance(
|
||||||
|
"node_with_inf_s3_retries",
|
||||||
|
main_configs=[
|
||||||
|
"configs/storage_conf.xml",
|
||||||
|
],
|
||||||
|
user_configs=[
|
||||||
|
"configs/setting.xml",
|
||||||
|
"configs/inf_s3_retries.xml",
|
||||||
|
],
|
||||||
|
with_minio=True,
|
||||||
|
)
|
||||||
logging.info("Starting cluster...")
|
logging.info("Starting cluster...")
|
||||||
cluster.start()
|
cluster.start()
|
||||||
logging.info("Cluster started")
|
logging.info("Cluster started")
|
||||||
@ -468,7 +479,7 @@ def test_when_s3_broken_pipe_at_upload_is_retried(cluster, broken_s3):
|
|||||||
|
|
||||||
|
|
||||||
def test_query_is_canceled_with_inf_retries(cluster, broken_s3):
|
def test_query_is_canceled_with_inf_retries(cluster, broken_s3):
|
||||||
node = cluster.instances["node"]
|
node = cluster.instances["node_with_inf_s3_retries"]
|
||||||
|
|
||||||
broken_s3.setup_at_part_upload(
|
broken_s3.setup_at_part_upload(
|
||||||
count=10000000,
|
count=10000000,
|
||||||
@ -490,7 +501,6 @@ def test_query_is_canceled_with_inf_retries(cluster, broken_s3):
|
|||||||
FROM system.numbers
|
FROM system.numbers
|
||||||
LIMIT 1000000
|
LIMIT 1000000
|
||||||
SETTINGS
|
SETTINGS
|
||||||
s3_retry_attempts=1000000,
|
|
||||||
s3_max_single_part_upload_size=100,
|
s3_max_single_part_upload_size=100,
|
||||||
s3_min_upload_part_size=10000,
|
s3_min_upload_part_size=10000,
|
||||||
s3_check_objects_after_upload=0
|
s3_check_objects_after_upload=0
|
||||||
|
@ -55,7 +55,11 @@ def started_cluster():
|
|||||||
"configs/named_collections.xml",
|
"configs/named_collections.xml",
|
||||||
"configs/schema_cache.xml",
|
"configs/schema_cache.xml",
|
||||||
],
|
],
|
||||||
user_configs=["configs/access.xml", "configs/users.xml", "configs/s3_retry.xml"],
|
user_configs=[
|
||||||
|
"configs/access.xml",
|
||||||
|
"configs/users.xml",
|
||||||
|
"configs/s3_retry.xml",
|
||||||
|
],
|
||||||
)
|
)
|
||||||
cluster.add_instance(
|
cluster.add_instance(
|
||||||
"dummy_without_named_collections",
|
"dummy_without_named_collections",
|
||||||
|
Loading…
Reference in New Issue
Block a user