This is an automated email from the ASF dual-hosted git repository. mmerli pushed a commit to branch branch-2.9 in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.9 by this push: new ce08aa3d77a Use OrderedExecutor instead of OrderedScheduler for consumer dispatch (#16115) ce08aa3d77a is described below commit ce08aa3d77a3b6548c27a7c03791e75a503e0c10 Author: Matteo Merli <mme...@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 a932e2fa505..b81200f7379 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 @@ -76,7 +76,6 @@ import lombok.AccessLevel; 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; @@ -301,7 +300,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");