From 95b8d80318e54def4cfec9f4825072f75c8cea1c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?J=C3=A1nos=20Benjamin=20Antal?= Date: Wed, 18 Sep 2024 18:26:56 +0000 Subject: [PATCH] Try to run kafka tests parallel --- tests/integration/parallel_skip.json | 68 ---------------------------- 1 file changed, 68 deletions(-) diff --git a/tests/integration/parallel_skip.json b/tests/integration/parallel_skip.json index 6767aa85be9..1b48b64593e 100644 --- a/tests/integration/parallel_skip.json +++ b/tests/integration/parallel_skip.json @@ -99,74 +99,6 @@ "test_ttl_move/test.py::TestCancelBackgroundMoving::test_cancel_background_moving_on_table_detach", "test_ttl_move/test.py::TestCancelBackgroundMoving::test_cancel_background_moving_on_zookeeper_disconnect", - "test_storage_kafka/test_1.py::test_kafka_consumer_failover", - "test_storage_kafka/test_1.py::test_row_based_formats", - "test_storage_kafka/test_1.py::test_kafka_duplicates_when_commit_failed", - "test_storage_kafka/test_1.py::test_commits_of_unprocessed_messages_on_drop", - "test_storage_kafka/test_1.py::test_kafka_produce_consume", - "test_storage_kafka/test_1.py::test_kafka_materialized_view", - "test_storage_kafka/test_1.py::test_kafka_materialized_view_with_subquery", - "test_storage_kafka/test_1.py::test_kafka_lot_of_partitions_partial_commit_of_bulk", - "test_storage_kafka/test_1.py::test_issue26643", - "test_storage_kafka/test_1.py::test_kafka_csv_with_thread_per_consumer", - "test_storage_kafka/test_1.py::test_kafka_select_empty", - "test_storage_kafka/test_1.py::test_kafka_issue11308", - "test_storage_kafka/test_1.py::test_kafka_protobuf", - "test_storage_kafka/test_1.py::test_kafka_predefined_configuration", - "test_storage_kafka/test_1.py::test_kafka_insert_avro", - "test_storage_kafka/test_1.py::test_exception_from_destructor", - "test_storage_kafka/test_2.py::test_kafka_unavailable", - "test_storage_kafka/test_2.py::test_bad_reschedule", - "test_storage_kafka/test_2.py::test_librdkafka_compression", - "test_storage_kafka/test_2.py::test_multiple_read_in_materialized_views", - "test_storage_kafka/test_2.py::test_kafka_virtual_columns2", - "test_storage_kafka/test_2.py::test_kafka_produce_key_timestamp", - "test_storage_kafka/test_2.py::test_kafka_engine_put_errors_to_stream_with_random_malformed_json", - "test_storage_kafka/test_2.py::test_kafka_produce_consume_avro", - "test_storage_kafka/test_2.py::test_kafka_virtual_columns_with_materialized_view", - "test_storage_kafka/test_2.py::test_system_kafka_consumers_rebalance_mv", - "test_storage_kafka/test_2.py::test_system_kafka_consumers", - "test_storage_kafka/test_2.py::test_kafka_insert", - "test_storage_kafka/test_2.py::test_kafka_settings_old_syntax", - "test_storage_kafka/test_2.py::test_kafka_json_without_delimiter", - "test_storage_kafka/test_2.py::test_kafka_string_field_on_first_position_in_protobuf", - "test_storage_kafka/test_2.py::test_block_based_formats_1", - "test_storage_kafka/test_3.py::test_formats_errors", - "test_storage_kafka/test_3.py::test_block_based_formats_2", - "test_storage_kafka/test_3.py::test_kafka_flush_on_big_message", - "test_storage_kafka/test_3.py::test_kafka_recreate_kafka_table", - "test_storage_kafka/test_3.py::test_kafka_commit_on_block_write", - "test_storage_kafka/test_3.py::test_kafka_no_holes_when_write_suffix_failed", - "test_storage_kafka/test_3.py::test_kafka_flush_by_block_size", - "test_storage_kafka/test_3.py::test_max_rows_per_message", - "test_storage_kafka/test_3.py::test_kafka_many_materialized_views", - "test_storage_kafka/test_3.py::test_kafka_engine_put_errors_to_stream", - "test_storage_kafka/test_3.py::test_kafka_producer_consumer_separate_settings", - "test_storage_kafka/test_3.py::test_kafka_virtual_columns", - "test_storage_kafka/test_3.py::test_kafka_settings_new_syntax", - "test_storage_kafka/test_3.py::test_kafka_tsv_with_delimiter", - "test_storage_kafka/test_3.py::test_kafka_csv_with_delimiter", - "test_storage_kafka/test_3.py::test_format_with_prefix_and_suffix", - "test_storage_kafka/test_4.py::test_kafka_formats_with_broken_message", - "test_storage_kafka/test_4.py::test_kafka_flush_by_time", - "test_storage_kafka/test_4.py::test_system_kafka_consumers_rebalance", - "test_storage_kafka/test_4.py::test_kafka_consumer_hang", - "test_storage_kafka/test_4.py::test_kafka_null_message", - "test_storage_kafka/test_4.py::test_kafka_read_consumers_in_parallel", - "test_storage_kafka/test_4.py::test_premature_flush_on_eof", - "test_storage_kafka/test_4.py::test_num_consumers_limit", - "test_storage_kafka/test_4.py::test_kafka_column_types", - "test_storage_kafka/test_4.py::test_kafka_protobuf_no_delimiter", - "test_storage_kafka/test_4.py::test_kafka_json_as_string", - "test_storage_kafka/test_4.py::test_kafka_settings_predefined_macros", - "test_storage_kafka/test_4.py::test_kafka_issue4116", - "test_storage_kafka/test_4.py::test_kafka_issue14202", - "test_storage_kafka/test_5.py::test_kafka_formats", - "test_storage_kafka/test_5.py::test_kafka_rebalance", - - - "test_storage_kafka/test_produce_http_interface.py::test_kafka_produce_http_interface_row_based_format", - "test_storage_kerberized_kafka/test.py::test_kafka_json_as_string", "test_storage_kerberized_kafka/test.py::test_kafka_json_as_string_request_new_ticket_after_expiration", "test_storage_kerberized_kafka/test.py::test_kafka_json_as_string_no_kdc",