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

Fix test_extreme_deduplication

Browse Source
This commit is contained in:
Alexey Milovidov 2023-07-09 04:17:15 +02:00
parent ab93967fb4
commit 7311469c32
1 changed files with 16 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
tests/integration/test_extreme_deduplication/test.py
View File

@ -49,20 +49,25 @@ def test_deduplication_window_in_seconds(started_cluster):
node.query("INSERT INTO simple VALUES (0, 1)")
assert TSV(node.query("SELECT count() FROM simple")) == TSV("2\n")
# wait clean thread
time.sleep(2)
# Wait for the cleanup thread.
for i in range(100):
time.sleep(1)
if (
TSV.toMat(
node.query(
"SELECT count() FROM system.zookeeper WHERE path = '/clickhouse/tables/0/simple/blocks'"
)
)[0][0]
<= "1"
):
break
else:
raise Exception("The blocks from Keeper were not removed in time")
assert (
TSV.toMat(
node.query(
"SELECT count() FROM system.zookeeper WHERE path='/clickhouse/tables/0/simple/blocks'"
)
)[0][0]
== "1"
)
node.query(
"INSERT INTO simple VALUES (0, 0)"
) # deduplication doesn't works here, the first hash node was deleted
) # Deduplication doesn't work here as the first hash node was deleted
assert TSV.toMat(node.query("SELECT count() FROM simple"))[0][0] == "3"
node1.query("""DROP TABLE simple ON CLUSTER test_cluster""")