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

test_kafka_no_holes_when_write_suffix_failed: Fix expected error message

Browse Source 
The old error message was incorrect (it said a failure happened when
pushing the prefix when it was happening while pushing the suffix.
This commit is contained in:
Raúl Marín 2021-07-19 11:50:33 +02:00
parent ff249a14af
commit 145699d0c2
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tests/integration/test_storage_kafka/test.py
View File

@ -2222,7 +2222,7 @@ def test_kafka_no_holes_when_write_suffix_failed(kafka_cluster):
# we have 0.25 (sleepEachRow) * 20 ( Rows ) = 5 sec window after "Polled batch of 20 messages" # we have 0.25 (sleepEachRow) * 20 ( Rows ) = 5 sec window after "Polled batch of 20 messages"
# while materialized view is working to inject zookeeper failure # while materialized view is working to inject zookeeper failure
pm.drop_instance_zk_connections(instance) pm.drop_instance_zk_connections(instance)
instance.wait_for_log_line("Error.*(session has been expired|Connection loss).*while writing prefix to view") instance.wait_for_log_line("Error.*(session has been expired|Connection loss).*while writing suffix to view")
pm.heal_all() pm.heal_all()
instance.wait_for_log_line("Committed offset 22") instance.wait_for_log_line("Committed offset 22")