You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by zh...@apache.org on 2022/09/07 06:15:06 UTC
[pulsar] branch master updated: remove unnecessary parameters(reusefuture) and related logic (#17378)
This is an automated email from the ASF dual-hosted git repository.
zhangmingao 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 f453e0a5b7a remove unnecessary parameters(reusefuture) and related logic (#17378)
f453e0a5b7a is described below
commit f453e0a5b7a57c2fdfeabc3f2d8778cc70dbc16a
Author: HuangZeGui <10...@qq.com>
AuthorDate: Wed Sep 7 14:14:57 2022 +0800
remove unnecessary parameters(reusefuture) and related logic (#17378)
Co-authored-by: huangzegui <hu...@didiglobal.com>
---
.../src/main/java/org/apache/pulsar/broker/admin/AdminResource.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/AdminResource.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/AdminResource.java
index 5362982a7e0..3a779845168 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/AdminResource.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/AdminResource.java
@@ -157,13 +157,13 @@ public abstract class AdminResource extends PulsarWebResource {
}
List<CompletableFuture<Void>> futures = new ArrayList<>(numPartitions);
for (int i = 0; i < numPartitions; i++) {
- futures.add(tryCreatePartitionAsync(i, null));
+ futures.add(tryCreatePartitionAsync(i));
}
return FutureUtil.waitForAll(futures);
}
- private CompletableFuture<Void> tryCreatePartitionAsync(final int partition, CompletableFuture<Void> reuseFuture) {
- CompletableFuture<Void> result = reuseFuture == null ? new CompletableFuture<>() : reuseFuture;
+ private CompletableFuture<Void> tryCreatePartitionAsync(final int partition) {
+ CompletableFuture<Void> result = new CompletableFuture<>();
getPulsarResources().getTopicResources().createPersistentTopicAsync(topicName.getPartition(partition))
.thenAccept(r -> {
if (log.isDebugEnabled()) {