From 12377bd3c64ee2f5ab50e4f268eee938279f29df Mon Sep 17 00:00:00 2001 From: Ron Dagostino Date: Mon, 17 May 2021 17:33:43 -0400 Subject: [PATCH] MINOR: Add missing @cluster annotation to StreamsNamedRepartitionTopicTest (#10697) The StreamsNamedRepartitionTopicTest system tests did not have the @cluster annotation and was therefore taking up the entire cluster. For example, we see this in the log output: kafkatest.tests.streams.streams_named_repartition_topic_test.StreamsNamedRepartitionTopicTest.test_upgrade_topology_with_named_repartition_topic is using entire cluster. It's possible this test has no associated cluster metadata. This PR adds the missing annotation. Reviewers: Bill Bejeck --- .../tests/streams/streams_named_repartition_topic_test.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/tests/kafkatest/tests/streams/streams_named_repartition_topic_test.py b/tests/kafkatest/tests/streams/streams_named_repartition_topic_test.py index 1fcdd5fbe11..ce270d303a6 100644 --- a/tests/kafkatest/tests/streams/streams_named_repartition_topic_test.py +++ b/tests/kafkatest/tests/streams/streams_named_repartition_topic_test.py @@ -13,6 +13,7 @@ # See the License for the specific language governing permissions and # limitations under the License. +from ducktape.mark.resource import cluster from ducktape.tests.test import Test from kafkatest.services.kafka import KafkaService from kafkatest.services.streams import StreamsNamedRepartitionTopicService @@ -50,6 +51,7 @@ class StreamsNamedRepartitionTopicTest(Test): throughput=1000, acks=1) + @cluster(num_nodes=8) def test_upgrade_topology_with_named_repartition_topic(self): self.zookeeper.start() self.kafka.start()