thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-21 15:12:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

Adjust exception message in test_replicated_fetches_timeouts

Browse Source
This commit is contained in:
vdimir 2021-07-15 11:58:21 +03:00
parent e2280aad18
commit dd3e1a8a4d
No known key found for this signature in database
GPG Key ID: F57B3E10A21DBB31
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -78,7 +78,7 @@ def test_no_stall(started_cluster):
"""
SELECT count()
FROM system.replication_queue
WHERE last_exception LIKE '%e.displayText() = Timeout%'
WHERE last_exception LIKE '%Timeout%'
AND last_exception NOT LIKE '%connect timed out%'
""").strip())

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

@ -66,7 +66,7 @@ def get_kafka_producer(port, serializer, retries):
except Exception as e:
errors += [str(e)]
time.sleep(1)
raise Exception("Connection not establised, {}".format(errors))
def producer_serializer(x):
@ -1339,7 +1339,7 @@ def test_librdkafka_compression(kafka_cluster):
Example of corruption:
2020.12.10 09:59:56.831507 [ 20 ] {} <Error> void DB::StorageKafka::threadFunc(size_t): Code: 27, e.displayText() = DB::Exception: Cannot parse input: expected '"' before: 'foo"}': (while reading the value of key value): (at row 1)
2020.12.10 09:59:56.831507 [ 20 ] {} <Error> void DB::StorageKafka::threadFunc(size_t): Code: 27. DB::Exception: Cannot parse input: expected '"' before: 'foo"}': (while reading the value of key value): (at row 1)
To trigger this regression there should duplicated messages