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

Simplify TTL move test

Browse Source
This commit is contained in:
alesapin 2020-10-21 13:11:26 +03:00
parent c53f59dece
commit e090a119fc
1 changed files with 10 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
tests/integration/test_ttl_move/test.py
View File

@ -900,7 +900,10 @@ def test_concurrent_alter_with_ttl_move(started_cluster, name, engine):
def alter_update(num): def alter_update(num):
for i in range(num): for i in range(num):
node1.query("ALTER TABLE {} UPDATE number = number + 1 WHERE 1".format(name)) try:
node1.query("ALTER TABLE {} UPDATE number = number + 1 WHERE 1".format(name))
except:
pass
def alter_modify_ttl(num): def alter_modify_ttl(num):
for i in range(num): for i in range(num):
@ -927,17 +930,17 @@ def test_concurrent_alter_with_ttl_move(started_cluster, name, engine):
p = Pool(15) p = Pool(15)
tasks = [] tasks = []
for i in range(5): for i in range(5):
tasks.append(p.apply_async(insert, (100,))) tasks.append(p.apply_async(insert, (30,)))
tasks.append(p.apply_async(alter_move, (100,))) tasks.append(p.apply_async(alter_move, (30,)))
tasks.append(p.apply_async(alter_update, (100,))) tasks.append(p.apply_async(alter_update, (30,)))
tasks.append(p.apply_async(alter_modify_ttl, (100,))) tasks.append(p.apply_async(alter_modify_ttl, (30,)))
tasks.append(p.apply_async(optimize_table, (100,))) tasks.append(p.apply_async(optimize_table, (30,)))
for task in tasks: for task in tasks:
task.get(timeout=120) task.get(timeout=120)
assert node1.query("SELECT 1") == "1\n" assert node1.query("SELECT 1") == "1\n"
assert node1.query("SELECT COUNT() FROM {}".format(name)) == "500\n" assert node1.query("SELECT COUNT() FROM {}".format(name)) == "150\n"
finally: finally:
node1.query("DROP TABLE IF EXISTS {name} NO DELAY".format(name=name)) node1.query("DROP TABLE IF EXISTS {name} NO DELAY".format(name=name))