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

Merge pull request #44938 from ClickHouse/try-fix-test_multiple_disks-test_freeze

Browse Source 
Stop merges to avoid a race between merge and freeze.
This commit is contained in:
Nikolai Kochetov 2023-01-06 12:45:10 +01:00 committed by GitHub
commit 12192ef099
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 19 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -407,9 +407,7 @@ def test_alter_policy(start_cluster, name, engine):
def get_random_string(length):
return "".join(
random.choice(string.ascii_uppercase + string.digits) for _ in range(length)
)
return "randomPrintableASCII({})".format(length)
def get_used_disks_for_table(node, table_name):
@ -554,7 +552,7 @@ def test_max_data_part_size(start_cluster, name, engine):
node1.query_with_retry(
"INSERT INTO {} VALUES {}".format(
name, ",".join(["('" + x + "')" for x in data])
name, ",".join(["(" + x + ")" for x in data])
)
)
used_disks = get_used_disks_for_table(node1, name)
@ -605,7 +603,7 @@ def test_jbod_overflow(start_cluster, name, engine):
data.append(get_random_string(1024 * 1024)) # 1MB row
node1.query_with_retry(
"INSERT INTO {} VALUES {}".format(
name, ",".join(["('" + x + "')" for x in data])
name, ",".join(["(" + x + ")" for x in data])
)
)
@ -619,7 +617,7 @@ def test_jbod_overflow(start_cluster, name, engine):
node1.query_with_retry(
"INSERT INTO {} VALUES {}".format(
name, ",".join(["('" + x + "')" for x in data])
name, ",".join(["(" + x + ")" for x in data])
)
)
@ -684,7 +682,7 @@ def test_background_move(start_cluster, name, engine):
# small jbod size is 40MB, so lets insert 5MB batch 5 times
node1.query_with_retry(
"INSERT INTO {} VALUES {}".format(
name, ",".join(["('" + x + "')" for x in data])
name, ",".join(["(" + x + ")" for x in data])
)
)
@ -702,8 +700,9 @@ def test_background_move(start_cluster, name, engine):
# first (oldest) part was moved to external
assert used_disks[0] == "external"
node1.query("SYSTEM FLUSH LOGS")
path = node1.query(
"SELECT path_on_disk FROM system.part_log WHERE table = '{}' AND event_type='MovePart' ORDER BY event_time LIMIT 1".format(
"SELECT path_on_disk FROM system.part_log WHERE table = '{}' AND event_type='MovePart' AND part_name = 'all_1_1_0'".format(
name
)
)
@ -796,7 +795,7 @@ def test_start_stop_moves(start_cluster, name, engine):
# jbod size is 40MB, so lets insert 5MB batch 7 times
node1.query_with_retry(
"INSERT INTO {} VALUES {}".format(
name, ",".join(["('" + x + "')" for x in data])
name, ",".join(["(" + x + ")" for x in data])
)
)
@ -1310,7 +1309,7 @@ def test_detach_attach(start_cluster, name, engine):
data.append(get_random_string(1024 * 1024)) # 1MB row
node1.query_with_retry(
"INSERT INTO {} VALUES {}".format(
name, ",".join(["('" + x + "')" for x in data])
name, ",".join(["(" + x + ")" for x in data])
)
)
@ -1362,7 +1361,7 @@ def test_mutate_to_another_disk(start_cluster, name, engine):
data.append(get_random_string(1024 * 1024)) # 1MB row
node1.query_with_retry(
"INSERT INTO {} VALUES {}".format(
name, ",".join(["('" + x + "')" for x in data])
name, ",".join(["(" + x + ")" for x in data])
)
)
@ -1511,7 +1510,7 @@ def test_simple_replication_and_moves(start_cluster):
data.append(get_random_string(512 * 1024)) # 500KB value
node.query_with_retry(
"INSERT INTO replicated_table_for_moves VALUES {}".format(
",".join(["('" + x + "')" for x in data])
",".join(["(" + x + ")" for x in data])
)
)
@ -1546,12 +1545,12 @@ def test_simple_replication_and_moves(start_cluster):
node1.query_with_retry(
"INSERT INTO replicated_table_for_moves VALUES {}".format(
",".join(["('" + x + "')" for x in data])
",".join(["(" + x + ")" for x in data])
)
)
node2.query_with_retry(
"INSERT INTO replicated_table_for_moves VALUES {}".format(
",".join(["('" + x + "')" for x in data])
",".join(["(" + x + ")" for x in data])
)
)
@ -1589,7 +1588,7 @@ def test_download_appropriate_disk(start_cluster):
data.append(get_random_string(1024 * 1024)) # 1MB value
node1.query_with_retry(
"INSERT INTO replicated_table_for_download VALUES {}".format(
",".join(["('" + x + "')" for x in data])
",".join(["(" + x + ")" for x in data])
)
)
@ -1632,7 +1631,7 @@ def test_rename(start_cluster):
data.append(get_random_string(1024 * 1024)) # 1MB value
node1.query(
"INSERT INTO renaming_table VALUES {}".format(
",".join(["('" + x + "')" for x in data])
",".join(["(" + x + ")" for x in data])
)
)
@ -1673,6 +1672,8 @@ def test_freeze(start_cluster):
"""
)
node1.query("SYSTEM STOP MERGES default.freezing_table")
for _ in range(5):
data = []
dates = []
@ -1681,7 +1682,7 @@ def test_freeze(start_cluster):
dates.append("toDate('2019-03-05')")
node1.query(
"INSERT INTO freezing_table VALUES {}".format(
",".join(["(" + d + ", '" + s + "')" for d, s in zip(dates, data)])
",".join(["(" + d + ", " + s + ")" for d, s in zip(dates, data)])
)
)
@ -1725,7 +1726,7 @@ def test_kill_while_insert(start_cluster):
data.append(get_random_string(1024 * 1024)) # 1MB value
node1.query(
"INSERT INTO {name} VALUES {}".format(
",".join(["('" + s + "')" for s in data]), name=name
",".join(["(" + s + ")" for s in data]), name=name
)
)