diff --git a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/loadbalance/ExtensibleLoadManagerTest.java b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/loadbalance/ExtensibleLoadManagerTest.java index 899296448199a..1909cb4572068 100644 --- a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/loadbalance/ExtensibleLoadManagerTest.java +++ b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/loadbalance/ExtensibleLoadManagerTest.java @@ -141,28 +141,37 @@ public void startBroker() { brokerContainer.start(); } }); - String topicName = "persistent://" + DEFAULT_NAMESPACE + "/startBrokerCheck"; - Awaitility.await().atMost(120, TimeUnit.SECONDS).ignoreExceptions().until( - () -> { - for (BrokerContainer brokerContainer : pulsarCluster.getBrokers()) { - try (PulsarAdmin admin = PulsarAdmin.builder().serviceHttpUrl( - brokerContainer.getHttpServiceUrl()).build()) { + + Awaitility.await() + .atMost(4, TimeUnit.MINUTES) + .ignoreExceptions() + .until(() -> { + for (BrokerContainer broker : pulsarCluster.getBrokers()) { + try (PulsarAdmin admin = PulsarAdmin.builder() + .serviceHttpUrl(broker.getHttpServiceUrl()).build()) { if (admin.brokers().getActiveBrokers(clusterName).size() != NUM_BROKERS) { return false; } - try { - admin.topics().createPartitionedTopic(topicName, 10); - } catch (PulsarAdminException.ConflictException e) { - // expected - } - admin.lookups().lookupPartitionedTopic(topicName); } } return true; + }); + + String topicName = "persistent://" + DEFAULT_NAMESPACE + "/startBrokerCheck"; + for (BrokerContainer broker : pulsarCluster.getBrokers()) { + try (PulsarAdmin admin = PulsarAdmin.builder() + .serviceHttpUrl(broker.getHttpServiceUrl()).build()) { + try { + admin.topics().createPartitionedTopic(topicName, 10); + } catch (PulsarAdminException.ConflictException e) { + // expected } - ); + admin.lookups().lookupPartitionedTopic(topicName); + } + } } } + @Test(timeOut = 40 * 1000) public void testConcurrentLookups() throws Exception {