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

Select the materialized view only once

Browse Source
This commit is contained in:
Ivan Lezhankin 2019-01-23 19:12:41 +03:00
parent c50583126e
commit 20b94a635c
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
dbms/tests/integration/test_storage_kafka/test.py
View File

@ -60,7 +60,7 @@ def kafka_produce(kafka_id, topic, messages):
p.stdin.close()
def kafka_check_json_numbers(instance, insert_malformed=False, table='test.kafka'):
def kafka_check_json_numbers(instance, insert_malformed=False, table='test.kafka', select_count=3):
retries = 0
while True:
if kafka_is_available(instance.cluster.kafka_docker_id):
@ -88,9 +88,9 @@ def kafka_check_json_numbers(instance, insert_malformed=False, table='test.kafka
kafka_produce(instance.cluster.kafka_docker_id, 'json', messages)
# XXX: since the broken message breaks the `select` reading
# we'll try to select 3 times - to be sure.
# we'll try to select a limited number of times.
result = ''
for i in range(3):
for i in range(select_count):
time.sleep(1)
result += instance.query('SELECT * FROM {};'.format(table))
@ -154,7 +154,7 @@ def test_kafka_json_materialized_view(started_cluster):
SELECT * FROM test.kafka;
''')
kafka_check_json_numbers(instance, True, 'test.view')
kafka_check_json_numbers(instance, True, 'test.view', 1)
instance.query('''
DROP TABLE test.kafka;