From f08d46108d0bcdb30380a4834ad9dd5b74fb2045 Mon Sep 17 00:00:00 2001 From: rdhabalia Date: Mon, 2 Mar 2020 12:04:44 -0800 Subject: [PATCH] pulsar-proxy: fix correct name for proxy thread executor name --- .../apache/pulsar/proxy/server/util/ZookeeperCacheLoader.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/util/ZookeeperCacheLoader.java b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/util/ZookeeperCacheLoader.java index c3afdec9ec381..82dd42c5e19f6 100644 --- a/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/util/ZookeeperCacheLoader.java +++ b/pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/util/ZookeeperCacheLoader.java @@ -54,7 +54,7 @@ public class ZookeeperCacheLoader implements Closeable { private volatile List availableBrokers; private final OrderedScheduler orderedExecutor = OrderedScheduler.newSchedulerBuilder().numThreads(8) - .name("pulsar-discovery-ordered-cache").build(); + .name("pulsar-proxy-ordered-cache").build(); public static final String LOADBALANCE_BROKERS_ROOT = "/loadbalance/brokers";