This is an automated email from the ASF dual-hosted git repository.
baodi 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 1a8608700e7 Fix compilation failed afting cherry-picked #24150
1a8608700e7 is described below
commit 1a8608700e71a240c9d374ae3a06ea3d05d7705e
Author: Baodi Shi <[email protected]>
AuthorDate: Mon Apr 14 14:51:54 2025 +0800
Fix compilation failed afting cherry-picked #24150
---
.../org/apache/pulsar/broker/service/ReplicationTopicGcTest.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicationTopicGcTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicationTopicGcTest.java
index 267e8547914..852e33b8e7c 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicationTopicGcTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicationTopicGcTest.java
@@ -119,9 +119,9 @@ public class ReplicationTopicGcTest extends
OneWayReplicatorTestBase {
.getPartitionedTopicResources().partitionedTopicExists(TopicName.get(topicName)));
// topic policies.
assertTrue(pulsar1.getTopicPoliciesService().getTopicPoliciesAsync(TopicName.get(topicName),
- TopicPoliciesService.GetType.DEFAULT).get().isEmpty());
+ false).get().isEmpty());
assertTrue(pulsar2.getTopicPoliciesService().getTopicPoliciesAsync(TopicName.get(topicName),
- TopicPoliciesService.GetType.DEFAULT).get().isEmpty());
+ false).get().isEmpty());
// schema.
assertTrue(CollectionUtils.isEmpty(pulsar1.getSchemaStorage().getAll(schemaId).get()));
assertTrue(CollectionUtils.isEmpty(pulsar2.getSchemaStorage().getAll(schemaId).get()));
@@ -169,7 +169,7 @@ public class ReplicationTopicGcTest extends
OneWayReplicatorTestBase {
.getPartitionedTopicResources().partitionedTopicExists(TopicName.get(topicName)));
// topic policies.
assertTrue(pulsar1.getTopicPoliciesService().getTopicPoliciesAsync(TopicName.get(topicName),
- TopicPoliciesService.GetType.DEFAULT).get().isEmpty());
+ false).get().isEmpty());
// schema.
assertTrue(CollectionUtils.isEmpty(pulsar1.getSchemaStorage().getAll(schemaId).get()));
});