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

These queries need to be run in the same session

Browse Source
This commit is contained in:
Joe Lynch 2023-08-21 12:50:20 +02:00
parent 8d0824f1b8
commit 075c0261e9
No known key found for this signature in database
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
tests/integration/test_restart_server/test.py
View File

@ -24,11 +24,13 @@ def test_drop_memory_database():
def test_flushes_async_insert_queue():
node.query(
"CREATE TABLE flush_test (a String, b UInt64) ENGINE = MergeTree ORDER BY a;"
"""
CREATE TABLE flush_test (a String, b UInt64) ENGINE = MergeTree ORDER BY a;
SET async_insert = 1;
SET wait_for_async_insert = 0;
SET async_insert_busy_timeout_ms = 1000000;
INSERT INTO flush_test VALUES ('world', 23456);
"""
)
node.query("SET async_insert = 1;")
node.query("SET wait_for_async_insert = 0;")
node.query("SET async_insert_busy_timeout_ms = 1000000;")
node.query("INSERT INTO flush_test VALUES ('world', 23456);")
node.restart_clickhouse()
assert node.query("SELECT * FROM flush_test") == "world\t23456\n"