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

I hope now

Browse Source
This commit is contained in:
kssenii 2024-01-26 13:15:15 +01:00
parent 0c82926b95
commit 7515fa99f4
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
tests/integration/test_broken_projections/test.py
View File

@ -226,12 +226,14 @@ def check(node, table, check_result, expect_broken_part="", expected_error=""):
f"SELECT c FROM '{table}' WHERE d == 12 ORDER BY c",
query_id=query_id,
)
time.sleep(2)
node.query("SYSTEM FLUSH LOGS")
assert "proj1" in node.query(
f"""
SYSTEM FLUSH LOGS;
SELECT query, splitByChar('.', arrayJoin(projections))[-1]
FROM system.query_log
WHERE current_database=currentDatabase() AND query_id='{query_id}' AND type='QueryFinish'
WHERE query_id='{query_id}' AND type='QueryFinish'
"""
)
@ -246,12 +248,14 @@ def check(node, table, check_result, expect_broken_part="", expected_error=""):
f"SELECT d FROM '{table}' WHERE c == 12 OR c == 16 ORDER BY d",
query_id=query_id,
)
time.sleep(2)
node.query("SYSTEM FLUSH LOGS")
assert "proj2" in node.query(
f"""
SYSTEM FLUSH LOGS;
SELECT query, splitByChar('.', arrayJoin(projections))[-1]
FROM system.query_log
WHERE current_database=currentDatabase() AND query_id='{query_id}' AND type='QueryFinish'
WHERE query_id='{query_id}' AND type='QueryFinish'
"""
)