This is an automated email from the ASF dual-hosted git repository.

technoboy pushed a commit to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-4.0 by this push:
     new 7e6be251920 [fix][broker]Fix the wrong logic of the test 
PartitionCreationTest.testCreateMissedPartitions (#24683)
7e6be251920 is described below

commit 7e6be2519201aa94a4008116bbb75ef6121de3e2
Author: fengyubiao <yubiao.f...@streamnative.io>
AuthorDate: Mon Sep 1 16:03:01 2025 +0800

    [fix][broker]Fix the wrong logic of the test 
PartitionCreationTest.testCreateMissedPartitions (#24683)
---
 .../test/java/org/apache/pulsar/client/api/PartitionCreationTest.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/PartitionCreationTest.java
 
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/PartitionCreationTest.java
index b3b9c9cec2c..03d568cb855 100644
--- 
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/PartitionCreationTest.java
+++ 
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/PartitionCreationTest.java
@@ -151,7 +151,7 @@ public class PartitionCreationTest extends 
ProducerConsumerBase {
                 .createPartitionedTopicAsync(TopicName.get(topic),
                 new PartitionedTopicMetadata(numPartitions)).join();
         Assert.assertEquals(admin.topics().getList("public/default").stream()
-            .filter(tp -> 
TopicName.get(topic).getPartitionedTopicName().endsWith(topic)).toList().size(),
 0);
+            .filter(tp -> 
TopicName.get(tp).getPartitionedTopicName().endsWith(topic)).toList().size(), 
0);
         if (useRestApi) {
             admin.topics().createMissedPartitions(topic);
         } else {

Reply via email to