thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-20 00:30:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix oldest part fetching

Browse Source
This commit is contained in:
Antonio Andelic 2023-07-05 17:43:09 +00:00
parent 47cffa6f1e
commit b60a1c53d6
1 changed files with 7 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

@ -717,9 +717,10 @@ def test_background_move(start_cluster, name, engine):
node1.query(f"SYSTEM STOP MERGES {name}")
first_part = None
for i in range(5):
data = [] # 5MB in total
for i in range(5):
for _ in range(5):
data.append(get_random_string(1024 * 1024)) # 1MB row
# small jbod size is 40MB, so lets insert 5MB batch 5 times
node1.query_with_retry(
@ -728,7 +729,11 @@ def test_background_move(start_cluster, name, engine):
)
)
first_part = get_oldest_part(node1, name)
# we are doing moves in parallel so we need to fetch the name of first part before we add new parts
if i == 0:
first_part = get_oldest_part(node1, name)
assert first_part is not None
used_disks = get_used_disks_for_table(node1, name)