avoid race in librdkafka

see https://github.com/edenhill/librdkafka/issues/3279
This commit is contained in:
filimonov 2021-03-04 15:01:10 +01:00 committed by GitHub
parent 218542589a
commit bd8c3eb117
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -2454,6 +2454,8 @@ def test_kafka_issue14202(kafka_cluster):
kafka_format = 'JSONEachRow'; kafka_format = 'JSONEachRow';
''') ''')
time.sleep(3)
instance.query( instance.query(
'INSERT INTO test.kafka_q SELECT t, some_string FROM ( SELECT dt AS t, some_string FROM test.empty_table )') 'INSERT INTO test.kafka_q SELECT t, some_string FROM ( SELECT dt AS t, some_string FROM test.empty_table )')
# check instance is alive # check instance is alive