From c5b0a4d0c803e624113a8b1b0065e516172be090 Mon Sep 17 00:00:00 2001 From: Ron Dagostino Date: Tue, 2 Mar 2021 15:18:40 -0500 Subject: [PATCH] MINOR: disable round_trip_fault_test system tests for Raft quorums --- tests/kafkatest/tests/core/round_trip_fault_test.py | 5 ----- 1 file changed, 5 deletions(-) diff --git a/tests/kafkatest/tests/core/round_trip_fault_test.py b/tests/kafkatest/tests/core/round_trip_fault_test.py index b9085cb8b5b71..d8873b2d84235 100644 --- a/tests/kafkatest/tests/core/round_trip_fault_test.py +++ b/tests/kafkatest/tests/core/round_trip_fault_test.py @@ -75,13 +75,11 @@ def remote_quorum_nodes(self): return [] @cluster(num_nodes=9) - @matrix(metadata_quorum=quorum.all_non_upgrade) def test_round_trip_workload(self, metadata_quorum=quorum.zk): workload1 = self.trogdor.create_task("workload1", self.round_trip_spec) workload1.wait_for_done(timeout_sec=600) @cluster(num_nodes=9) - @matrix(metadata_quorum=quorum.all_non_upgrade) def test_round_trip_workload_with_broker_partition(self, metadata_quorum=quorum.zk): workload1 = self.trogdor.create_task("workload1", self.round_trip_spec) time.sleep(2) @@ -95,7 +93,6 @@ def test_round_trip_workload_with_broker_partition(self, metadata_quorum=quorum. partition1.wait_for_done() @cluster(num_nodes=9) - @matrix(metadata_quorum=quorum.all_non_upgrade) def test_produce_consume_with_broker_pause(self, metadata_quorum=quorum.zk): workload1 = self.trogdor.create_task("workload1", self.round_trip_spec) time.sleep(2) @@ -108,7 +105,6 @@ def test_produce_consume_with_broker_pause(self, metadata_quorum=quorum.zk): self.kafka.stop_node(self.kafka.nodes[0], False) @cluster(num_nodes=9) - @matrix(metadata_quorum=quorum.all_non_upgrade) def test_produce_consume_with_client_partition(self, metadata_quorum=quorum.zk): workload1 = self.trogdor.create_task("workload1", self.round_trip_spec) time.sleep(2) @@ -121,7 +117,6 @@ def test_produce_consume_with_client_partition(self, metadata_quorum=quorum.zk): stop1.wait_for_done() @cluster(num_nodes=9) - @matrix(metadata_quorum=quorum.all_non_upgrade) def test_produce_consume_with_latency(self, metadata_quorum=quorum.zk): workload1 = self.trogdor.create_task("workload1", self.round_trip_spec) time.sleep(2)