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

Update test.py

Browse Source 
Missed one of the refactorings which were merged in the meanwhile 872e36c207 (diff-8129a3b04ff2293c2d89b35395be9ef49918cdafd4420a745d05733b00979646L86-R100)
This commit is contained in:
filimonov 2021-06-09 12:27:42 +02:00 committed by GitHub
parent 1172807442
commit 7469f054f0
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1316,7 +1316,7 @@ def test_kafka_recreate_kafka_table(kafka_cluster):
messages = []
for i in range(120):
messages.append(json.dumps({'key': i, 'value': i}))
kafka_produce('recreate_kafka_table', messages)
kafka_produce(kafka_cluster,'recreate_kafka_table', messages)
instance.wait_for_log_line('kafka.*Committed offset [0-9]+.*recreate_kafka_table', repetitions=6, look_behind_lines=100)
@ -1324,7 +1324,7 @@ def test_kafka_recreate_kafka_table(kafka_cluster):
DROP TABLE test.kafka;
''')
kafka_produce('recreate_kafka_table', messages)
kafka_produce(kafka_cluster,'recreate_kafka_table', messages)
instance.query('''
CREATE TABLE test.kafka (key UInt64, value UInt64)