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

Fix kafka test

Browse Source
This commit is contained in:
alesapin 2022-01-31 19:18:34 +03:00
parent 93c0700c4c
commit ace8169732
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

@ -1572,7 +1572,7 @@ def test_kafka_virtual_columns_with_materialized_view(kafka_cluster):
messages.append(json.dumps({'key': i, 'value': i})) messages.append(json.dumps({'key': i, 'value': i}))
kafka_produce(kafka_cluster, 'virt2', messages, 0) kafka_produce(kafka_cluster, 'virt2', messages, 0)
sql = 'SELECT kafka_key, key, topic, value, offset, partition, timestamp FROM test.view ORDER BY kafka_key' sql = 'SELECT kafka_key, key, topic, value, offset, partition, timestamp FROM test.view ORDER BY kafka_key, key'
result = instance.query(sql) result = instance.query(sql)
iterations = 0 iterations = 0
while not kafka_check_result(result, False, 'test_kafka_virtual2.reference') and iterations < 10: while not kafka_check_result(result, False, 'test_kafka_virtual2.reference') and iterations < 10: