You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by lh...@apache.org on 2024/11/23 21:42:59 UTC
(pulsar) 02/02: [fix][test][branch-3.3] Fix OneWayReplicatorUsingGlobalZKTest#testRemoveCluster
This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch branch-3.3
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit a7107f97b89c73bfd43b01ae440016cd0d42f5e7
Author: Lari Hotari <lh...@apache.org>
AuthorDate: Sat Nov 23 23:32:03 2024 +0200
[fix][test][branch-3.3] Fix OneWayReplicatorUsingGlobalZKTest#testRemoveCluster
---
.../broker/service/OneWayReplicatorUsingGlobalZKTest.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorUsingGlobalZKTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorUsingGlobalZKTest.java
index 83b9b32ce85..58653b89525 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorUsingGlobalZKTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorUsingGlobalZKTest.java
@@ -198,18 +198,18 @@ public class OneWayReplicatorUsingGlobalZKTest extends OneWayReplicatorTest {
// The topics under the namespace of the cluster-1 will be deleted.
// Verify the result.
admin1.namespaces().setNamespaceReplicationClusters(ns1, new HashSet<>(Arrays.asList(cluster2)));
- Awaitility.await().atMost(Duration.ofSeconds(120)).untilAsserted(() -> {
+ Awaitility.await().atMost(Duration.ofSeconds(60)).ignoreExceptions().untilAsserted(() -> {
ConcurrentOpenHashMap<String, CompletableFuture<Optional<Topic>>> tps
= pulsar1.getBrokerService().getTopics();
assertFalse(tps.containsKey(topic));
assertFalse(tps.containsKey(topicChangeEvents));
- assertFalse(pulsar1.getNamespaceService().checkTopicExists(TopicName.get(topic)).join().isExists());
+ assertFalse(pulsar1.getNamespaceService().checkTopicExists(TopicName.get(topic))
+ .get(5, TimeUnit.SECONDS).isExists());
assertFalse(pulsar1.getNamespaceService()
- .checkTopicExists(TopicName.get(topicChangeEvents)).join().isExists());
+ .checkTopicExists(TopicName.get(topicChangeEvents))
+ .get(5, TimeUnit.SECONDS).isExists());
});
- Thread.sleep(10 * 60 * 1000);
-
// cleanup.
p.close();
admin2.topics().delete(topic);