You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by te...@apache.org on 2025/09/01 08:03:07 UTC
(pulsar) branch master updated: [fix][broker]Fix the wrong logic of the test PartitionCreationTest.testCreateMissedPartitions (#24683)
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 <yu...@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 {