You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2022/06/19 15:51:08 UTC
[pulsar] branch branch-2.10 updated: Use OrderedExecutor instead of OrderedScheduler for consumer dispatch (#16115)
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch branch-2.10
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.10 by this push:
new 06d967ae9e7 Use OrderedExecutor instead of OrderedScheduler for consumer dispatch (#16115)
06d967ae9e7 is described below
commit 06d967ae9e7f2b4059bb396ebe2d15415c1ecdd5
Author: Matteo Merli <mm...@apache.org>
AuthorDate: Sun Jun 19 05:27:30 2022 -0700
Use OrderedExecutor instead of OrderedScheduler for consumer dispatch (#16115)
---
.../src/main/java/org/apache/pulsar/broker/service/BrokerService.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
index 3aa0c73ae8e..a4840d9f52f 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
@@ -78,7 +78,6 @@ import lombok.AllArgsConstructor;
import lombok.Getter;
import lombok.Setter;
import org.apache.bookkeeper.common.util.OrderedExecutor;
-import org.apache.bookkeeper.common.util.OrderedScheduler;
import org.apache.bookkeeper.mledger.AsyncCallbacks.DeleteLedgerCallback;
import org.apache.bookkeeper.mledger.AsyncCallbacks.OpenLedgerCallback;
import org.apache.bookkeeper.mledger.LedgerOffloader;
@@ -309,7 +308,7 @@ public class BrokerService implements Closeable {
ConcurrentOpenHashMap.<TopicName,
PersistentOfflineTopicStats>newBuilder().build();
- this.topicOrderedExecutor = OrderedScheduler.newSchedulerBuilder()
+ this.topicOrderedExecutor = OrderedExecutor.newBuilder()
.numThreads(pulsar.getConfiguration().getNumWorkerThreadsForNonPersistentTopic())
.name("broker-topic-workers").build();
final DefaultThreadFactory acceptorThreadFactory = new DefaultThreadFactory("pulsar-acceptor");