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

fix test case

Browse Source
This commit is contained in:
Peng Jian 2021-04-08 07:19:57 +08:00
parent 604ba9db60
commit 16e971ee52
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -2859,8 +2859,8 @@ def test_kafka_formats_with_broken_message(kafka_cluster):
val3 UInt8
) ENGINE = Kafka()
SETTINGS kafka_broker_list = 'kafka1:19092',
kafka_topic_list = '{topic_name}',
kafka_group_name = '{topic_name}_group',
kafka_topic_list = 'stream_{topic_name}',
kafka_group_name = 'stream_{topic_name}_group',
kafka_format = '{format_name}',
kafka_handle_error_mode = 'stream',
kafka_flush_interval_ms = 1000 {extra_settings};
@ -2877,8 +2877,6 @@ def test_kafka_formats_with_broken_message(kafka_cluster):
'''.format(topic_name=topic_name, format_name=format_name, raw_message=raw_message,
extra_settings=format_opts.get('extra_settings') or ''))
#DROP TABLE IF EXISTS test.kafka_errors_{format_name}_mv;
for format_name, format_opts in list(all_formats.items()):
print(('Checking {}'.format(format_name)))
topic_name = 'format_tests_{}'.format(format_name)