Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[fix][client] Use dedicated executor for requests in BinaryProtoLookupService #23378

Open
wants to merge 4 commits into
base: master
Choose a base branch
from
+139 −23
Open

[fix][client] Use dedicated executor for requests in BinaryProtoLookupService #23378

Changes from 1 commit
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
ebea662
[fix][client] Use dedicated executor for requests in BinaryProtoLooku…
nodece Oct 10, 2024
e59a1f9
Revert scheduledExecutorProvider
nodece Oct 11, 2024
7ac2448
inverse createdLookupPinnedExecutor and fix constructor
nodece Oct 14, 2024
e52bd09
use the single thread as lookupExecutorProvider
nodece Oct 14, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
use the single thread as lookupExecutorProvider 
Signed-off-by: Zixuan Liu <nodeces@gmail.com>
  • Loading branch information
@nodece
nodece committed Oct 14, 2024
commit e52bd097d268c0ecb2d3fc5a89fd4578d325358c
2 changes: 1 addition & 1 deletion pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -232,7 +232,7 @@ private PulsarClientImpl(ClientConfigurationData conf, EventLoopGroup eventLoopG
this.internalExecutorProvider = internalExecutorProvider != null ? internalExecutorProvider :
new ExecutorProvider(conf.getNumIoThreads(), "pulsar-client-internal");
this.lookupExecutorProvider = lookupExecutorProvider != null ? lookupExecutorProvider :
new ExecutorProvider(conf.getNumIoThreads(), "pulsar-client-lookup");
new ExecutorProvider(1, "pulsar-client-lookup");
if (conf.getServiceUrl().startsWith("http")) {
lookup = new HttpLookupService(instrumentProvider, conf, this.eventLoopGroup);
} else {
Expand Down
Loading