This is an automated email from the ASF dual-hosted git repository. technoboy 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 82f2371826b [fix][broker]Fix the wrong logic of the test PartitionCreationTest.testCreateMissedPartitions (#24683) 82f2371826b is described below commit 82f2371826ba95bd617e8b0042df161977e2caf0 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 8a88a4169b5..78ea4de93d2 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 {