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 2025/04/23 07:40:21 UTC
(pulsar) branch branch-3.3 updated: [fix][test] Fix flaky NamespacesTest.testNamespacesApiRedirects (#24194)
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
The following commit(s) were added to refs/heads/branch-3.3 by this push:
new 825e3b1be7f [fix][test] Fix flaky NamespacesTest.testNamespacesApiRedirects (#24194)
825e3b1be7f is described below
commit 825e3b1be7ffd62e55c82acd97d112b1a03b782d
Author: Lari Hotari <lh...@users.noreply.github.com>
AuthorDate: Wed Apr 23 07:26:06 2025 +0300
[fix][test] Fix flaky NamespacesTest.testNamespacesApiRedirects (#24194)
(cherry picked from commit c3d71abcd7e1580fa5c21f2905452997236607db)
---
.../src/test/java/org/apache/pulsar/broker/admin/NamespacesTest.java | 2 ++
1 file changed, 2 insertions(+)
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/NamespacesTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/NamespacesTest.java
index 16f9ac7d3a3..7213abe4557 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/NamespacesTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/NamespacesTest.java
@@ -721,6 +721,7 @@ public class NamespacesTest extends MockedPulsarServiceBaseTest {
+ this.testLocalNamespaces.get(2).toString() + "/unload");
doReturn(uri).when(uriInfo).getRequestUri();
+ response = mock(AsyncResponse.class);
namespaces.unloadNamespaceBundle(response, this.testTenant, this.testOtherCluster,
this.testLocalNamespaces.get(2).getLocalName(), "0x00000000_0xffffffff", false, null);
captor = ArgumentCaptor.forClass(WebApplicationException.class);
@@ -730,6 +731,7 @@ public class NamespacesTest extends MockedPulsarServiceBaseTest {
UriBuilder.fromUri(uri).host("127.0.0.3").port(8083).toString());
// check the bundle should not unload to an inactive destination broker
+ response = mock(AsyncResponse.class);
namespaces.unloadNamespaceBundle(response, this.testTenant, this.testOtherCluster,
this.testLocalNamespaces.get(2).getLocalName(), "0x00000000_0xffffffff", false, "inactive_destination:8080");
captor = ArgumentCaptor.forClass(WebApplicationException.class);