thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-28 02:21:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

Black

Browse Source
This commit is contained in:
Nikolai Kochetov 2022-06-13 19:44:12 +00:00
parent 695d586604
commit 43dff9d34c
1 changed files with 26 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
tests/integration/test_distributed_format/test.py
View File

@ -6,7 +6,11 @@ import pytest
from helpers.cluster import ClickHouseCluster from helpers.cluster import ClickHouseCluster
cluster = ClickHouseCluster(__file__) cluster = ClickHouseCluster(__file__)
node = cluster.add_instance("node", main_configs=["configs/remote_servers.xml", 'configs/another_remote_servers.xml'], stay_alive=True) node = cluster.add_instance(
"node",
main_configs=["configs/remote_servers.xml", "configs/another_remote_servers.xml"],
stay_alive=True,
)
cluster_param = pytest.mark.parametrize( cluster_param = pytest.mark.parametrize(
"cluster", "cluster",
@ -144,6 +148,7 @@ def test_single_file_old(started_cluster, cluster):
node.query("drop table test.distr_3") node.query("drop table test.distr_3")
def test_remove_replica(started_cluster): def test_remove_replica(started_cluster):
node.query( node.query(
"create table test.local_4 (x UInt64, s String) engine = MergeTree order by x" "create table test.local_4 (x UInt64, s String) engine = MergeTree order by x"
@ -151,12 +156,28 @@ def test_remove_replica(started_cluster):
node.query( node.query(
"create table test.distr_4 (x UInt64, s String) engine = Distributed('test_cluster_remove_replica1', test, local_4)" "create table test.distr_4 (x UInt64, s String) engine = Distributed('test_cluster_remove_replica1', test, local_4)"
) )
node.query("insert into test.distr_4 values (1, 'a'), (2, 'bb'), (3, 'ccc'), (4, 'dddd')") node.query(
"insert into test.distr_4 values (1, 'a'), (2, 'bb'), (3, 'ccc'), (4, 'dddd')"
)
node.query("detach table test.distr_4") node.query("detach table test.distr_4")
node.exec_in_container(["sed", "-i", "s/test_cluster_remove_replica1/test_cluster_remove_replica_tmp/g", "/etc/clickhouse-server/config.d/another_remote_servers.xml"]) node.exec_in_container(
node.exec_in_container(["sed", "-i", "s/test_cluster_remove_replica2/test_cluster_remove_replica1/g", "/etc/clickhouse-server/config.d/another_remote_servers.xml"]) [
"sed",
"-i",
"s/test_cluster_remove_replica1/test_cluster_remove_replica_tmp/g",
"/etc/clickhouse-server/config.d/another_remote_servers.xml",
]
)
node.exec_in_container(
[
"sed",
"-i",
"s/test_cluster_remove_replica2/test_cluster_remove_replica1/g",
"/etc/clickhouse-server/config.d/another_remote_servers.xml",
]
)
node.query("SYSTEM RELOAD CONFIG") node.query("SYSTEM RELOAD CONFIG")
node.query("attach table test.distr_4", ignore_error=True) node.query("attach table test.distr_4", ignore_error=True)
node.query("SYSTEM FLUSH DISTRIBUTED test.distr_4", ignore_error=True) node.query("SYSTEM FLUSH DISTRIBUTED test.distr_4", ignore_error=True)
assert node.query("select 1") == '1\n' assert node.query("select 1") == "1\n"