92 Commits

Author	SHA1	Message	Date
Yatsishin Ilya	c59a11f798	Merge remote-tracking branch 'origin' into integration-2	2021-04-27 18:34:33 +03:00
Chao Ma	713eb9486c	Fix kafka storage does not work with arrow and arrowstream format messages	2021-04-21 19:44:09 +08:00
Yatsishin Ilya	f6d455732e	better	2021-04-14 19:04:17 +03:00
Yatsishin Ilya	db657c03c8	fix	2021-04-12 18:08:09 +03:00
Yatsishin Ilya	ec6adb692d	Merge remote-tracking branch 'origin' into integration-2	2021-04-12 10:04:11 +03:00
Peng Jian	f73faf1578	fix test case	2021-04-08 14:26:32 +08:00
Peng Jian	16e971ee52	fix test case	2021-04-08 07:19:57 +08:00
Peng Jian	604ba9db60	add test case	2021-04-07 20:15:15 +08:00
Peng Jian	e30c07db20	add test cases	2021-03-31 20:22:36 +08:00
Peng Jian	cc56302e8b	fix test case	2021-03-31 17:16:51 +08:00
Peng Jian	17a5fc6e0e	add test	2021-03-31 17:16:51 +08:00
Yatsishin Ilya	7b7580204c	fix	2021-03-28 00:26:53 +03:00
Yatsishin Ilya	fbf0fe6436	Merge remote-tracking branch 'origin' into integration-2	2021-03-20 22:47:33 +03:00
Vladimir	c8b5be636f	Merge pull request #21438 from arenadata/ADQM-170	2021-03-19 17:06:55 +03:00
Ilya Golshtein	518103f851	old Avro test data removed	2021-03-16 19:39:58 +03:00
Ilya Golshtein	abcf581005	avro bug with format_setting reference and a typo in kafka test	2021-03-15 12:19:33 +03:00
Ilya Golshtein	a579fcb424	kafka/avro works against table	2021-03-14 15:55:44 +03:00
Yatsishin Ilya	7bfa4bb64b	Merge remote-tracking branch 'origin' into integration-2	2021-03-09 10:33:15 +03:00
filimonov	bd8c3eb117	avoid race in librdkafka ... see https://github.com/edenhill/librdkafka/issues/3279	2021-03-04 15:01:10 +01:00
Yatsishin Ilya	298824c926	fix	2021-03-04 14:52:56 +03:00
Yatsishin Ilya	f03cf47a82	fix	2021-03-04 14:22:19 +03:00
Yatsishin Ilya	8122003c98	more fixes	2021-03-04 13:53:50 +03:00
Yatsishin Ilya	34609445f7	fix	2021-03-04 12:06:39 +03:00
Ilya Golshtein	f11a8cd13c	multimessage avro format for kafka test	2021-03-04 11:07:29 +03:00
Yatsishin Ilya	babea212c7	Merge remote-tracking branch 'origin' into integration-2	2021-03-03 11:56:15 +03:00
Mikhail Filimonov	9e3547681b	try to address python kafka client disconnects better	2021-02-26 07:17:31 +01:00
Mikhail Filimonov	60ede36068	simple fix for CI failure	2021-02-26 06:41:11 +01:00
Mikhail Filimonov	c4470ff283	proper placement for test	2021-02-26 06:38:14 +01:00
Mikhail Filimonov	2bcfff257c	Remove most of sleeps in tests	2021-02-25 17:02:59 +01:00
Mikhail Filimonov	6c6eaf2a60	Fixes	2021-02-25 17:02:57 +01:00
Mikhail Filimonov	a4c9e62d6d	Integration tests: introduce wait_for_log_line. ... It uses tail -f executed in container, this way i don't need to pull the file many times, rememeber positions etc.	2021-02-25 17:02:56 +01:00
Yatsishin Ilya	905cc7a2bd	fixes	2021-02-24 14:46:58 +03:00
Yatsishin Ilya	2df4317aba	wip	2021-02-19 00:21:50 +03:00
Yatsishin Ilya	609c9b272f	fix	2021-02-18 16:42:31 +03:00
Yatsishin Ilya	872e36c207	wip	2021-02-18 15:57:45 +03:00
Yatsishin Ilya	70963e4396	Fixed test_kafka_flush_by_time test.	2021-01-28 18:03:23 +03:00
Nikita Mikhaylov	736cc6959a	remove kafka flaky fix	2020-12-30 17:24:39 +03:00
filimonov	e81a99156f	Attempt to prevent test flap ... That extra SELECT is executed synchronously, after that all further actions will have a more stable timing.	2020-12-29 18:51:00 +01:00
Nikita Mikhailov	fbf2ac35e8	fix tsan	2020-12-17 18:14:09 +03:00
Azat Khuzhin	2e569899d1	Add a test for kafka with snappy compression method (regression for UB in snappy) ... I've checked it manually and it works with clang build and does not with gcc (there are NULL bytes in the middle of value).	2020-12-14 00:38:07 +03:00
filimonov	8e2ca9518b	Update test.py ... adjusting timeouts a bit, in the good hope that it will prevent flakiness of the test.	2020-12-11 10:13:03 +01:00
Mikhail Filimonov	b072bc7d2b	Test for the issue #12615	2020-11-06 17:54:44 +01:00
Mikhail Filimonov	e17d4e1eeb	Tests and some docs	2020-10-12 07:51:46 +02:00
Mikhail Filimonov	b602d18dd8	ProtobufSingle input format ... Allows to read Single protobuf message at once (w/o length-delemeters).	2020-10-12 07:51:36 +02:00
filimonov	1ce0d4dbc2	Update test.py ... similar change for test_kafka_duplicates_when_commit_failed	2020-10-10 23:36:59 +02:00
Mikhail Filimonov	60f4e561fb	fix test_kafka_produce_key_timestamp	2020-10-10 17:01:22 +02:00
Mikhail Filimonov	5fb549ca24	fix flap in no_holes_when_write_suffix_failed	2020-10-09 17:06:36 +02:00
Azat Khuzhin	9cb3c743bd	Convert to python3 (#15007)	2020-10-02 19:54:07 +03:00
bharatnc	b75963d370	Format and optimize imports in integration test files ... This PR formats all the `*.py` files found under the `tests/integration` folder. It also reorders the imports and cleans up a bunch of unused imports. The formatting also takes care of other things like wrapping lines and fixing spaces and indents such that the tests look more readable.	2020-09-15 23:10:54 -07:00
Peng Jian	77420c82ea	Add test case for Kafka engine with kafka_thread_per_consumer enabled.	2020-09-06 11:17:19 +08:00