You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by te...@apache.org on 2024/11/25 15:00:15 UTC
(pulsar) branch master updated: [improve][test] Reduce OneWayReplicatorUsingGlobalZKTest.testRemoveCluster execution time (#23633)
This is an automated email from the ASF dual-hosted git repository.
technoboy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 2126d4016e4 [improve][test] Reduce OneWayReplicatorUsingGlobalZKTest.testRemoveCluster execution time (#23633)
2126d4016e4 is described below
commit 2126d4016e43a21c044f2dd4f021fe7103ec83b0
Author: Lari Hotari <lh...@users.noreply.github.com>
AuthorDate: Mon Nov 25 17:00:06 2024 +0200
[improve][test] Reduce OneWayReplicatorUsingGlobalZKTest.testRemoveCluster execution time (#23633)
---
.../pulsar/broker/service/OneWayReplicatorUsingGlobalZKTest.java | 8 +++++---
1 file changed, 5 insertions(+), 3 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 ad877e8f947..9287b451c2c 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
@@ -203,13 +203,15 @@ 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(() -> {
Map<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());
});
// cleanup.