remove kafka flaky fix

This commit is contained in:
Nikita Mikhaylov 2020-12-30 17:24:39 +03:00 committed by GitHub
parent b94a654715
commit 736cc6959a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -1617,8 +1617,6 @@ def test_kafka_virtual_columns2(kafka_cluster):
kafka_num_consumers = 2,
kafka_format = 'JSONEachRow';
SELECT * FROM test.kafka;
CREATE MATERIALIZED VIEW test.view Engine=Log AS
SELECT value, _key, _topic, _partition, _offset, toUnixTimestamp(_timestamp), toUnixTimestamp64Milli(_timestamp_ms), _headers.name, _headers.value FROM test.kafka;
''')