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

CLICKHOUSE-3894: Remove retry and add sleep

Browse Source
This commit is contained in:
alesapin 2018-09-03 18:02:24 +03:00
parent 3719558bf7
commit ee8a8d82af
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
dbms/tests/integration/test_distributed_ddl/test.py
View File

@ -30,7 +30,7 @@ def ddl_check_query(instance, query, num_hosts=None):
if num_hosts is None:
num_hosts = len(cluster.instances)
contents = instance.query_with_retry(query, check_callback=lambda x: len(x.strip().split('\n')) == num_hosts)
contents = instance.query(query)
check_all_hosts_sucesfully_executed(contents, num_hosts)
return contents
@ -282,7 +282,9 @@ ENGINE = Distributed(cluster_without_replication, default, merge, i)
assert TSV(instance.query("SELECT i FROM all_merge_32 ORDER BY i")) == TSV(''.join(['{}\n'.format(x) for x in xrange(4)]))
time.sleep(5)
ddl_check_query(instance, "ALTER TABLE merge ON CLUSTER cluster_without_replication MODIFY COLUMN i Int64")
time.sleep(5)
ddl_check_query(instance, "ALTER TABLE merge ON CLUSTER cluster_without_replication ADD COLUMN s DEFAULT toString(i) FORMAT TSV")
assert TSV(instance.query("SELECT i, s FROM all_merge_64 ORDER BY i")) == TSV(''.join(['{}\t{}\n'.format(x,x) for x in xrange(4)]))