apache / apache/pulsar

[Bug] OneWayReplicatorTest/OneWayReplicatorUsingGlobalZKTest.testDeleteRemoteTopicByGlobalPolicy fails in branch-4.0

Open
#24,670 4 comments 0 reactions 0 assignees View on GitHub
type/bug
Dominant language
Java
Stars
15.3k
Forks
3.8k
Avg merge
1d 14h
Merged PRs (30d)
160

Description

### Search before reporting

- [x] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar.

### Read release policy

- [x] I understand that [unsupported versions](https://pulsar.apache.org/contribute/release-policy/#supported-versions) don't get bug fixes. I will attempt to reproduce the issue on a supported version of Pulsar client and Pulsar broker.

### User environment

branch-4.0 at d31657e
Pulsar CI job failed at https://github.com/apache/pulsar/actions/runs/17241363801/job/48920026682

### Issue Description

OneWayReplicatorTest.testDeleteRemoteTopicByGlobalPolicy and OneWayReplicatorUsingGlobalZKTest.testDeleteRemoteTopicByGlobalPolicy fail in branch-4.0

### Error messages

```text
Error: Tests run: 31, Failures: 1, Errors: 0, Skipped: 1, Time elapsed: 215.068 s <<< FAILURE! - in org.apache.pulsar.broker.service.OneWayReplicatorTest
Error: org.apache.pulsar.broker.service.OneWayReplicatorTest.testDeleteRemoteTopicByGlobalPolicy Time elapsed: 0.427 s <<< FAILURE!
org.apache.pulsar.client.admin.PulsarAdminException$NotFoundException: Topic persistent://public/default/tp_123-d8b10130-35d8-4524-b2af-1370d35fc3cb not found
at org.apache.pulsar.client.admin.PulsarAdminException.wrap(PulsarAdminException.java:252)
at org.apache.pulsar.client.admin.internal.BaseResource.sync(BaseResource.java:352)
at org.apache.pulsar.client.admin.internal.TopicPoliciesImpl.getReplicationClusters(TopicPoliciesImpl.java:1294)
at org.apache.pulsar.broker.service.OneWayReplicatorTest.lambda$testDeleteRemoteTopicByGlobalPolicy$1(OneWayReplicatorTest.java:218)
at org.awaitility.core.AssertionCondition.lambda$new$0(AssertionCondition.java:53)
at org.awaitility.core.ConditionAwaiter$ConditionPoller.call(ConditionAwaiter.java:248)
at org.awaitility.core.ConditionAwaiter$ConditionPoller.call(ConditionAwaiter.java:235)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
at java.base/java.lang.Thread.run(Thread.java:1583)
Suppressed: org.apache.pulsar.client.admin.PulsarAdminException$NotFoundException: Topic persistent://public/default/tp_123-d8b10130-35d8-4524-b2af-1370d35fc3cb not found

Error: Tests run: 12, Failures: 1, Errors: 0, Skipped: 1, Time elapsed: 83.846 s <<< FAILURE! - in org.apache.pulsar.broker.service.OneWayReplicatorUsingGlobalZKTest
Error: org.apache.pulsar.broker.service.OneWayReplicatorUsingGlobalZKTest.testDeleteRemoteTopicByGlobalPolicy Time elapsed: 0.699 s <<< FAILURE!
org.apache.pulsar.client.admin.PulsarAdminException$NotFoundException: Topic persistent://public/default/tp_123-6c52cb35-be6c-4700-9f05-7f4d5a21ade0 not found
at org.apache.pulsar.client.admin.PulsarAdminException.wrap(PulsarAdminException.java:252)
at org.apache.pulsar.client.admin.internal.BaseResource.sync(BaseResource.java:352)
at org.apache.pulsar.client.admin.internal.TopicPoliciesImpl.getReplicationClusters(TopicPoliciesImpl.java:1294)
at org.apache.pulsar.broker.service.OneWayReplicatorUsingGlobalZKTest.lambda$testDeleteRemoteTopicByGlobalPolicy$0(OneWayReplicatorUsingGlobalZKTest.java:95)
at org.awaitility.core.AssertionCondition.lambda$new$0(AssertionCondition.java:53)
at org.awaitility.core.ConditionAwaiter$ConditionPoller.call(ConditionAwaiter.java:248)
at org.awaitility.core.ConditionAwaiter$ConditionPoller.call(ConditionAwaiter.java:235)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
at java.base/java.lang.Thread.run(Thread.java:1583)
Suppressed: org.apache.pulsar.client.admin.PulsarAdminException$NotFoundException: Topic persistent://public/default/tp_123-6c52cb35-be6c-4700-9f05-7f4d5a21ade0 not found
at org.apache.pulsar.client.admin.internal.BaseResource.getApiException(BaseResource.java:283)
at org.apache.pulsar.client.admin.internal.BaseResource$FutureCallback.failed(BaseResource.java:373)
```

### Reproducing the issue

In branch-4.0:
```
mvn -DtestFailFast=false --fail-at-end -DredirectTestOutputToFile=false -DtestRetryCount=0 test -pl pulsar-broker -Dtest=OneWayReplicatorTest,OneWayReplicatorUsingGlobalZKTest
```

### Additional information

_No response_

### Are you willing to submit a PR?

- [ ] I'm willing to submit a PR!

Contributor guide

Open the contributing guide

Research direction

Run the provided Maven command in branch-4.0 for OneWayReplicatorTest and OneWayReplicatorUsingGlobalZKTest. Start at testDeleteRemoteTopicByGlobalPolicy around OneWayReplicatorTest.java:218 and OneWayReplicatorUsingGlobalZKTest.java:95, then inspect the Awaitility assertions and the reported TopicPoliciesImpl call. Done means both tests complete without the NotFoundException.

Written by the indexing model from the issue text.

Assessment

Tech stack
java
Domain
distributed-systems, testing
Issue type
Bug
Difficulty
3/5
Estimated time
1-2 days
Activity status
Stale
Clarity
Mostly clear
Newbie friendliness
35/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.