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

Retain some parts of the modification

Browse Source
This commit is contained in:
Alexey Milovidov 2020-05-30 21:43:14 +03:00
parent 9b4d6ac818
commit ff54b4c82b
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
tests/integration/test_part_log_table/test.py
View File

@ -21,7 +21,7 @@ def test_config_without_part_log(start_cluster):
node1.query("CREATE TABLE test_table(word String, value UInt64) ENGINE=MergeTree() ORDER BY value") node1.query("CREATE TABLE test_table(word String, value UInt64) ENGINE=MergeTree() ORDER BY value")
assert "Table system.part_log doesn't exist" in node1.query_and_get_error("SELECT * FROM system.part_log") assert "Table system.part_log doesn't exist" in node1.query_and_get_error("SELECT * FROM system.part_log")
node1.query("INSERT INTO test_table VALUES ('name', 1)") node1.query("INSERT INTO test_table VALUES ('name', 1)")
time.sleep(10) node1.query("SYSTEM FLUSH LOGS")
assert "Table system.part_log doesn't exist" in node1.query_and_get_error("SELECT * FROM system.part_log") assert "Table system.part_log doesn't exist" in node1.query_and_get_error("SELECT * FROM system.part_log")
def test_config_with_standard_part_log(start_cluster): def test_config_with_standard_part_log(start_cluster):
@ -29,7 +29,7 @@ def test_config_with_standard_part_log(start_cluster):
node2.query("CREATE TABLE test_table(word String, value UInt64) ENGINE=MergeTree() Order by value") node2.query("CREATE TABLE test_table(word String, value UInt64) ENGINE=MergeTree() Order by value")
assert "Table system.part_log doesn't exist" in node2.query_and_get_error("SELECT * FROM system.part_log") assert "Table system.part_log doesn't exist" in node2.query_and_get_error("SELECT * FROM system.part_log")
node2.query("INSERT INTO test_table VALUES ('name', 1)") node2.query("INSERT INTO test_table VALUES ('name', 1)")
time.sleep(10) node1.query("SYSTEM FLUSH LOGS")
assert node2.query("SELECT * FROM system.part_log") != "" assert node2.query("SELECT * FROM system.part_log") != ""
def test_config_with_non_standard_part_log(start_cluster): def test_config_with_non_standard_part_log(start_cluster):
@ -37,6 +37,6 @@ def test_config_with_non_standard_part_log(start_cluster):
node3.query("CREATE TABLE test_table(word String, value UInt64) ENGINE=MergeTree() Order by value") node3.query("CREATE TABLE test_table(word String, value UInt64) ENGINE=MergeTree() Order by value")
assert "Table system.table_name doesn't exist" in node3.query_and_get_error("SELECT * FROM system.table_name") assert "Table system.table_name doesn't exist" in node3.query_and_get_error("SELECT * FROM system.table_name")
node3.query("INSERT INTO test_table VALUES ('name', 1)") node3.query("INSERT INTO test_table VALUES ('name', 1)")
time.sleep(10) node1.query("SYSTEM FLUSH LOGS")
assert node3.query("SELECT * FROM system.table_name") != "" assert node3.query("SELECT * FROM system.table_name") != ""