From 2bd028dea395ebecd28e3df2bc9f2df7f5fdba3b Mon Sep 17 00:00:00 2001 From: penghui Date: Fri, 7 May 2021 23:02:49 +0800 Subject: [PATCH] Move out the key_shared related tests from the quarantine group. --- .../apache/pulsar/client/api/KeySharedSubscriptionTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/KeySharedSubscriptionTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/KeySharedSubscriptionTest.java index f249d5cad7737..e998a02afbc39 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/KeySharedSubscriptionTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/KeySharedSubscriptionTest.java @@ -631,7 +631,7 @@ public void testReadAheadWhenAddingConsumers() throws Exception { assertTrue(readPosition.getEntryId() < 1000); } - @Test(groups = "quarantine") + @Test public void testRemoveFirstConsumer() throws Exception { this.conf.setSubscriptionKeySharedEnable(true); String topic = "testReadAheadWhenAddingConsumers-" + UUID.randomUUID(); @@ -886,7 +886,7 @@ public void testContinueDispatchMessagesWhenMessageTTL() throws Exception { Assert.assertNotNull(consumer3.receive(1, TimeUnit.SECONDS)); } - @Test(dataProvider = "partitioned", groups = "quarantine") + @Test(dataProvider = "partitioned") public void testOrderingWithConsumerListener(boolean partitioned) throws Exception { final String topic = "persistent://public/default/key_shared-" + UUID.randomUUID(); if (partitioned) {