This is an automated email from the ASF dual-hosted git repository.
merlimat 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 1eb08ed7a7a [fix][test] Deflake TopicPoliciesTest.setupTestTopic by
retrying forced namespace deletion (#25974)
1eb08ed7a7a is described below
commit 1eb08ed7a7a2bf2771c83273e6010057db5228b8
Author: Lari Hotari <[email protected]>
AuthorDate: Mon Jun 8 23:42:01 2026 +0300
[fix][test] Deflake TopicPoliciesTest.setupTestTopic by retrying forced
namespace deletion (#25974)
---
.../org/apache/pulsar/broker/admin/TopicPoliciesTest.java | 15 +++++----------
1 file changed, 5 insertions(+), 10 deletions(-)
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/TopicPoliciesTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/TopicPoliciesTest.java
index f1e5d48f611..17ae9d343e4 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/TopicPoliciesTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/TopicPoliciesTest.java
@@ -175,16 +175,11 @@ public class TopicPoliciesTest extends
MockedPulsarServiceBaseTest {
} catch (PulsarAdminException.NotFoundException e) {
// topic may already be deleted
}
- try {
- admin.namespaces().deleteNamespace(myNamespace, true);
- } catch (PulsarAdminException.NotFoundException e) {
- // namespace may already be deleted
- }
- try {
- admin.namespaces().deleteNamespace(myNamespaceV1, true);
- } catch (PulsarAdminException.NotFoundException e) {
- // namespace may already be deleted
- }
+ // Use deleteNamespaceWithRetry since the forced namespace deletion
can fail transiently with HTTP 422 when a
+ // topic deletion in the cascade races with concurrent topic loading;
the helper retries and treats an
+ // already-deleted namespace as success.
+ deleteNamespaceWithRetry(myNamespace, true);
+ deleteNamespaceWithRetry(myNamespaceV1, true);
admin.namespaces().createNamespace(testTenant + "/" + testNamespace,
Set.of("test"));
admin.namespaces().createNamespace(myNamespaceV1);
admin.topics().createPartitionedTopic(testTopic, testTopicPartitions);