thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-23 16:12:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #52189 from ClickHouse/fix-test_multiple_disks

Browse Source 
Fix `test_multiple_disks/test.py::test_start_stop_moves`
This commit is contained in:
Antonio Andelic 2023-07-17 16:28:02 +02:00 committed by GitHub
commit bfe349a7e4
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
tests/integration/test_multiple_disks/test.py
View File

@ -818,9 +818,10 @@ def test_start_stop_moves(start_cluster, name, engine):
node1.query(f"SYSTEM STOP MOVES {name}") node1.query(f"SYSTEM STOP MOVES {name}")
node1.query(f"SYSTEM STOP MERGES {name}") node1.query(f"SYSTEM STOP MERGES {name}")
first_part = None
for i in range(5): for i in range(5):
data = [] # 5MB in total data = [] # 5MB in total
for i in range(5): for _ in range(5):
data.append(get_random_string(1024 * 1024)) # 1MB row data.append(get_random_string(1024 * 1024)) # 1MB row
# jbod size is 40MB, so lets insert 5MB batch 7 times # jbod size is 40MB, so lets insert 5MB batch 7 times
node1.query_with_retry( node1.query_with_retry(
@ -829,8 +830,14 @@ def test_start_stop_moves(start_cluster, name, engine):
) )
) )
# we cannot rely simply on modification time of part because it can be changed
# by different background operations so we explicitly check after the first
# part is inserted
if i == 0:
first_part = get_oldest_part(node1, name) first_part = get_oldest_part(node1, name)
assert first_part is not None
used_disks = get_used_disks_for_table(node1, name) used_disks = get_used_disks_for_table(node1, name)
retry = 5 retry = 5