[GitHub] [pulsar] wmfxly opened a new issue #12682: Pulsar Transaction msg stop application throw executor not accepting a task

GitBox Mon, 08 Nov 2021 18:49:38 -0800


wmfxly opened a new issue #12682:
URL: https://github.com/apache/pulsar/issues/12682



   
   Describe the bug：
   I use pulsar 2.8.1 version, open the transaction message, after sending the 
message, stop the service, and receive an exception. The exception information 
is as follows:
   org.apache.pulsar.client.api.PulsarClientException: 
java.util.concurrent.CompletionException: java.lang.IllegalStateException: 
executor not accepting a task
   at 
org.apache.pulsar.client.impl.ConnectionPool.lambda$createConnection$9(ConnectionPool.java:216)
   at 
org.apache.pulsar.shade.io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
   at 
org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472)
   at 
org.apache.pulsar.shade.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
   at 
org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
   at 
org.apache.pulsar.shade.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
   at 
org.apache.pulsar.shade.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
   at java.lang.Thread.run(Thread.java:745)
   
   while many times start,stop
   
   
   Source code:
   import lombok.extern.slf4j.Slf4j;
   import org.apache.pulsar.client.api.PulsarClient;
   import org.apache.pulsar.client.api.PulsarClientException;
   import org.apache.pulsar.client.api.SizeUnit;
   import org.apache.pulsar.shade.io.netty.util.concurrent.DefaultThreadFactory;
   
   import java.util.concurrent.Executors;
   import java.util.concurrent.ScheduledExecutorService;
   import java.util.concurrent.TimeUnit;
   
   @Slf4j
   public class DemoPulsarClientInitUltimate {
   
       private static final String SERVICE_URL = "pulsar://xx.xx.xx.xx:6650";
       private static final DemoPulsarClientInitUltimate INSTANCE = new 
DemoPulsarClientInitUltimate();
       private volatile PulsarClient pulsarClient;
       private final ScheduledExecutorService executorService = 
Executors.newScheduledThreadPool(1, new 
DefaultThreadFactory("pulsar-cli-init"));
   
       public static DemoPulsarClientInitUltimate getInstance() {
           return INSTANCE;
       }
   
       public void init() {
           executorService.scheduleWithFixedDelay(this::initWithRetry, 0, 10, 
TimeUnit.SECONDS);
       }
   
       private void initWithRetry() {
           try {
               pulsarClient = PulsarClient.builder()
                       .serviceUrl(SERVICE_URL)
                       .enableTransaction(true)
                       .ioThreads(4)
                       .listenerThreads(10)
                       .memoryLimit(64, SizeUnit.MEGA_BYTES)
                       .operationTimeout(5, TimeUnit.SECONDS)
                       .connectionTimeout(15, TimeUnit.SECONDS)
                       .build();
   
               log.info("pulsar client init success");
               this.executorService.shutdown();
           } catch (PulsarClientException e) {
               e.printStackTrace();
           }
       }
   
       public PulsarClient getPulsarClient() {
           return pulsarClient;
       }
   
   
       public static void main(String[] args) throws Exception {
           DemoPulsarClientInitUltimate instance = 
DemoPulsarClientInitUltimate.getInstance();
           instance.init();
           Thread.sleep(5000L);
   
           //PulsarClient pulsarClient = instance.getPulsarClient();
           if (null != instance) {
               instance.pulsarClient.close();
           }
       }
   }
   
   
   Environmental information:
   win10
   jdk8
   
   
   **Expected behavior**
   safe close applicaiton
   
   **Additional context**
   11:10:11.145 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.util.internal.logging.InternalLoggerFactory - 
Using SLF4J as the default logging framework
   11:10:11.150 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.util.internal.InternalThreadLocalMap - 
-Dio.netty.threadLocalMap.stringBuilder.initialSize: 1024
   11:10:11.150 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.util.internal.InternalThreadLocalMap - 
-Dio.netty.threadLocalMap.stringBuilder.maxSize: 4096
   11:10:11.218 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.channel.MultithreadEventLoopGroup - 
-Dio.netty.eventLoopThreads: 12
   11:10:11.245 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.channel.nio.NioEventLoop - 
-Dio.netty.noKeySetOptimization: false
   11:10:11.245 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.channel.nio.NioEventLoop - 
-Dio.netty.selectorAutoRebuildThreshold: 512
   11:10:11.262 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.util.internal.PlatformDependent - Platform: 
Windows
   11:10:11.264 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.util.internal.PlatformDependent0 - 
-Dio.netty.noUnsafe: false
   11:10:11.264 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.util.internal.PlatformDependent0 - Java 
version: 8
   11:10:11.265 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.util.internal.PlatformDependent0 - 
sun.misc.Unsafe.theUnsafe: available
   11:10:11.266 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.util.internal.PlatformDependent0 - 
sun.misc.Unsafe.copyMemory: available
   11:10:11.267 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.util.internal.PlatformDependent0 - 
java.nio.Buffer.address: available
   11:10:11.267 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.util.internal.PlatformDependent0 - direct 
buffer constructor: available
   11:10:11.268 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.util.internal.PlatformDependent0 - 
java.nio.Bits.unaligned: available, true
   11:10:11.269 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.util.internal.PlatformDependent0 - 
jdk.internal.misc.Unsafe.allocateUninitializedArray(int): unavailable prior to 
Java9
   11:10:11.269 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.util.internal.PlatformDependent0 - 
java.nio.DirectByteBuffer.<init>(long, int): available
   11:10:11.269 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.util.internal.PlatformDependent - 
sun.misc.Unsafe: available
   11:10:11.269 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.util.internal.PlatformDependent - 
-Dio.netty.tmpdir: C:\Users\ADMINI~1\AppData\Local\Temp (java.io.tmpdir)
   11:10:11.270 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.util.internal.PlatformDependent - 
-Dio.netty.bitMode: 64 (sun.arch.data.model)
   11:10:11.271 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.util.internal.PlatformDependent - 
-Dio.netty.maxDirectMemory: 7622623232 bytes
   11:10:11.271 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.util.internal.PlatformDependent - 
-Dio.netty.uninitializedArrayAllocationThreshold: -1
   11:10:11.272 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.util.internal.CleanerJava6 - 
java.nio.ByteBuffer.cleaner(): available
   11:10:11.272 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.util.internal.PlatformDependent - 
-Dio.netty.noPreferDirect: false
   11:10:11.282 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.util.internal.PlatformDependent - 
org.jctools-core.MpscChunkedArrayQueue: available
   11:10:11.313 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.common.allocator.PulsarByteBufAllocator - Is Pooled: true -- 
Exit on OOM: false
   11:10:11.330 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.util.ResourceLeakDetector - 
-Dorg.apache.pulsar.shade.io.netty.leakDetection.level: simple
   11:10:11.330 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.util.ResourceLeakDetector - 
-Dorg.apache.pulsar.shade.io.netty.leakDetection.targetRecords: 4
   11:10:11.332 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.buffer.PooledByteBufAllocator - 
-Dio.netty.allocator.numHeapArenas: 12
   11:10:11.332 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.buffer.PooledByteBufAllocator - 
-Dio.netty.allocator.numDirectArenas: 12
   11:10:11.332 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.buffer.PooledByteBufAllocator - 
-Dio.netty.allocator.pageSize: 8192
   11:10:11.332 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.buffer.PooledByteBufAllocator - 
-Dio.netty.allocator.maxOrder: 11
   11:10:11.332 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.buffer.PooledByteBufAllocator - 
-Dio.netty.allocator.chunkSize: 16777216
   11:10:11.332 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.buffer.PooledByteBufAllocator - 
-Dio.netty.allocator.smallCacheSize: 256
   11:10:11.332 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.buffer.PooledByteBufAllocator - 
-Dio.netty.allocator.normalCacheSize: 64
   11:10:11.332 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.buffer.PooledByteBufAllocator - 
-Dio.netty.allocator.maxCachedBufferCapacity: 32768
   11:10:11.332 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.buffer.PooledByteBufAllocator - 
-Dio.netty.allocator.cacheTrimInterval: 8192
   11:10:11.332 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.buffer.PooledByteBufAllocator - 
-Dio.netty.allocator.cacheTrimIntervalMillis: 0
   11:10:11.332 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.buffer.PooledByteBufAllocator - 
-Dio.netty.allocator.useCacheForAllThreads: true
   11:10:11.332 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.buffer.PooledByteBufAllocator - 
-Dio.netty.allocator.maxCachedByteBuffersPerChunk: 1023
   11:10:11.349 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.org.apache.bookkeeper.common.allocator.impl.ByteBufAllocatorImpl
 - Disable Netty allocator leak detector
   11:10:11.366 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.util.NetUtil - -Djava.net.preferIPv4Stack: 
false
   11:10:11.366 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.util.NetUtil - -Djava.net.preferIPv6Addresses: 
false
   11:10:11.481 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.util.NetUtilInitializations - Loopback 
interface: lo (Software Loopback Interface 1, 127.0.0.1)
   11:10:11.482 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.util.NetUtil - Failed to get SOMAXCONN from 
sysctl and file \proc\sys\net\core\somaxconn. Default: 200
   11:10:11.618 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.resolver.dns.DefaultDnsServerAddressStreamProvider
 - Default DNS servers: [/222.88.88.88:53, /114.114.114.114:53] 
(sun.net.dns.ResolverConfiguration)
   11:10:11.648 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.channel.DefaultChannelId - 
-Dio.netty.processId: 26964 (auto-detected)
   11:10:11.770 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.channel.DefaultChannelId - 
-Dio.netty.machineId: 2c:f0:5d:ff:fe:ab:6c:49 (auto-detected)
   11:10:11.797 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.buffer.ByteBufUtil - 
-Dio.netty.allocator.type: pooled
   11:10:11.797 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.buffer.ByteBufUtil - 
-Dio.netty.threadLocalDirectBufferSize: 0
   11:10:11.797 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.buffer.ByteBufUtil - 
-Dio.netty.maxThreadLocalCharBufferSize: 16384
   11:10:11.893 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.shade.io.netty.util.ResourceLeakDetectorFactory - Loaded 
default ResourceLeakDetector: 
org.apache.pulsar.shade.io.netty.util.ResourceLeakDetector@2af7c4a3
   11:10:11.922 [pulsar-cli-init-1-1] DEBUG 
org.apache.pulsar.client.impl.ConnectionPool - Connection for xx.xx.xx.xx:6650 
not found in cache
   11:10:11.944 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.shade.io.netty.util.Recycler - 
-Dio.netty.recycler.maxCapacityPerThread: 4096
   11:10:11.944 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.shade.io.netty.util.Recycler - 
-Dio.netty.recycler.maxSharedCapacityFactor: 2
   11:10:11.944 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.shade.io.netty.util.Recycler - 
-Dio.netty.recycler.linkCapacity: 16
   11:10:11.944 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.shade.io.netty.util.Recycler - -Dio.netty.recycler.ratio: 8
   11:10:11.945 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.shade.io.netty.util.Recycler - 
-Dio.netty.recycler.delayedQueue.ratio: 8
   11:10:11.986 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.shade.io.netty.buffer.AbstractByteBuf - 
-Dorg.apache.pulsar.shade.io.netty.buffer.checkAccessible: true
   11:10:11.986 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.shade.io.netty.buffer.AbstractByteBuf - 
-Dorg.apache.pulsar.shade.io.netty.buffer.checkBounds: true
   11:10:11.986 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.shade.io.netty.util.ResourceLeakDetectorFactory - Loaded 
default ResourceLeakDetector: 
org.apache.pulsar.shade.io.netty.util.ResourceLeakDetector@724cd059
   11:10:12.007 [pulsar-client-io-2-2] INFO 
org.apache.pulsar.client.impl.ConnectionPool - [[id: 0x8adaadde, 
L:/xx.16.10.82:10345 - R:/xx.xx.xx.xx:6650]] Connected to server
   11:10:12.017 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.common.protocol.PulsarHandler - [[id: 0x8adaadde, 
L:/xx.16.10.82:10345 - R:/xx.xx.xx.xx:6650]] Scheduling keep-alive task every 
30 s
   11:10:12.018 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.client.impl.ClientCnx - [id: 0x8adaadde, L:/xx.16.10.82:10345 
- R:/xx.xx.xx.xx:6650] Connected to broker
   11:10:12.024 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.client.impl.ClientCnx - Complete: true
   11:10:12.033 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.common.protocol.PulsarDecoder - [/xx.xx.xx.xx:6650] Received 
cmd CONNECTED
   11:10:12.034 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.client.impl.ClientCnx - [id: 0x8adaadde, L:/xx.16.10.82:10345 
- R:/xx.xx.xx.xx:6650] Connection has max message size setting, replace old 
frameDecoder with server frame size 5242880
   11:10:12.034 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.client.impl.ClientCnx - [id: 0x8adaadde, L:/xx.16.10.82:10345 
- R:/xx.xx.xx.xx:6650] Connection is ready
   11:10:12.034 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.client.impl.ConnectionPool - [[id: 0x8adaadde, 
L:/xx.16.10.82:10345 - R:/xx.xx.xx.xx:6650]] Connection handshake completed
   11:10:12.040 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.common.protocol.PulsarDecoder - [/xx.xx.xx.xx:6650] Received 
cmd PARTITIONED_METADATA_RESPONSE
   11:10:12.040 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.client.impl.ClientCnx - Received Broker Partition response: 16
   11:10:12.040 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.client.impl.transaction.TransactionCoordinatorClientImpl - 
Transaction meta store assign partition is 16.
   11:10:12.061 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.common.protocol.PulsarDecoder - [/xx.xx.xx.xx:6650] Received 
cmd LOOKUP_RESPONSE
   11:10:12.061 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.client.impl.ClientCnx - Received Broker lookup response: 
Connect
   11:10:12.061 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.client.impl.ConnectionPool - Connection for 
xx.16.200.102:6650 not found in cache
   11:10:12.062 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.common.protocol.PulsarDecoder - [/xx.xx.xx.xx:6650] Received 
cmd LOOKUP_RESPONSE
   11:10:12.062 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.client.impl.ClientCnx - Received Broker lookup response: 
Connect
   11:10:12.062 [pulsar-client-io-2-2] INFO 
org.apache.pulsar.client.impl.TransactionMetaStoreHandler - Transaction meta 
handler with transaction coordinator id 1 connection opened.
   11:10:12.062 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.common.protocol.PulsarDecoder - [/xx.xx.xx.xx:6650] Received 
cmd LOOKUP_RESPONSE
   11:10:12.062 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.client.impl.ClientCnx - Received Broker lookup response: 
Connect
   11:10:12.062 [pulsar-client-io-2-2] INFO 
org.apache.pulsar.client.impl.TransactionMetaStoreHandler - Transaction meta 
handler with transaction coordinator id 2 connection opened.
   11:10:12.062 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.common.protocol.PulsarDecoder - [/xx.xx.xx.xx:6650] Received 
cmd LOOKUP_RESPONSE
   11:10:12.062 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.client.impl.ClientCnx - Received Broker lookup response: 
Connect
   11:10:12.062 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.common.protocol.PulsarDecoder - [/xx.xx.xx.xx:6650] Received 
cmd LOOKUP_RESPONSE
   11:10:12.062 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.client.impl.ClientCnx - Received Broker lookup response: 
Connect
   11:10:12.062 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.common.protocol.PulsarDecoder - [/xx.xx.xx.xx:6650] Received 
cmd LOOKUP_RESPONSE
   11:10:12.062 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.client.impl.ClientCnx - Received Broker lookup response: 
Connect
   11:10:12.063 [pulsar-client-io-2-2] INFO 
org.apache.pulsar.client.impl.TransactionMetaStoreHandler - Transaction meta 
handler with transaction coordinator id 5 connection opened.
   11:10:12.063 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.common.protocol.PulsarDecoder - [/xx.xx.xx.xx:6650] Received 
cmd LOOKUP_RESPONSE
   11:10:12.063 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.client.impl.ClientCnx - Received Broker lookup response: 
Connect
   11:10:12.063 [pulsar-client-io-2-2] INFO 
org.apache.pulsar.client.impl.TransactionMetaStoreHandler - Transaction meta 
handler with transaction coordinator id 6 connection opened.
   11:10:12.063 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.common.protocol.PulsarDecoder - [/xx.xx.xx.xx:6650] Received 
cmd LOOKUP_RESPONSE
   11:10:12.063 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.client.impl.ClientCnx - Received Broker lookup response: 
Connect
   11:10:12.063 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.common.protocol.PulsarDecoder - [/xx.xx.xx.xx:6650] Received 
cmd LOOKUP_RESPONSE
   11:10:12.063 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.client.impl.ClientCnx - Received Broker lookup response: 
Connect
   11:10:12.063 [pulsar-client-io-2-4] INFO 
org.apache.pulsar.client.impl.ConnectionPool - [[id: 0xc39b56e0, 
L:/xx.16.10.82:10346 - R:/xx.16.200.102:6650]] Connected to server
   11:10:12.063 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.common.protocol.PulsarDecoder - [/xx.xx.xx.xx:6650] Received 
cmd LOOKUP_RESPONSE
   11:10:12.063 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.client.impl.ClientCnx - Received Broker lookup response: 
Connect
   11:10:12.063 [pulsar-client-io-2-4] DEBUG 
org.apache.pulsar.common.protocol.PulsarHandler - [[id: 0xc39b56e0, 
L:/xx.16.10.82:10346 - R:/xx.16.200.102:6650]] Scheduling keep-alive task every 
30 s
   11:10:12.063 [pulsar-client-io-2-2] INFO 
org.apache.pulsar.client.impl.TransactionMetaStoreHandler - Transaction meta 
handler with transaction coordinator id 9 connection opened.
   11:10:12.063 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.common.protocol.PulsarDecoder - [/xx.xx.xx.xx:6650] Received 
cmd LOOKUP_RESPONSE
   11:10:12.063 [pulsar-client-io-2-4] DEBUG 
org.apache.pulsar.client.impl.ClientCnx - [id: 0xc39b56e0, L:/xx.16.10.82:10346 
- R:/xx.16.200.102:6650] Connected to broker
   11:10:12.063 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.client.impl.ClientCnx - Received Broker lookup response: 
Connect
   11:10:12.064 [pulsar-client-io-2-2] INFO 
org.apache.pulsar.client.impl.TransactionMetaStoreHandler - Transaction meta 
handler with transaction coordinator id 10 connection opened.
   11:10:12.064 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.common.protocol.PulsarDecoder - [/xx.xx.xx.xx:6650] Received 
cmd LOOKUP_RESPONSE
   11:10:12.064 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.client.impl.ClientCnx - Received Broker lookup response: 
Connect
   11:10:12.064 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.common.protocol.PulsarDecoder - [/xx.xx.xx.xx:6650] Received 
cmd LOOKUP_RESPONSE
   11:10:12.064 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.client.impl.ClientCnx - Received Broker lookup response: 
Connect
   11:10:12.064 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.client.impl.ConnectionPool - Connection for xx.16.200.96:6650 
not found in cache
   11:10:12.064 [pulsar-client-io-2-4] DEBUG 
org.apache.pulsar.client.impl.ClientCnx - Complete: true
   11:10:12.064 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.common.protocol.PulsarDecoder - [/xx.xx.xx.xx:6650] Received 
cmd LOOKUP_RESPONSE
   11:10:12.064 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.client.impl.ClientCnx - Received Broker lookup response: 
Connect
   11:10:12.064 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.common.protocol.PulsarDecoder - [/xx.xx.xx.xx:6650] Received 
cmd LOOKUP_RESPONSE
   11:10:12.064 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.client.impl.ClientCnx - Received Broker lookup response: 
Connect
   11:10:12.064 [pulsar-client-io-2-2] INFO 
org.apache.pulsar.client.impl.TransactionMetaStoreHandler - Transaction meta 
handler with transaction coordinator id 14 connection opened.
   11:10:12.064 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.common.protocol.PulsarDecoder - [/xx.xx.xx.xx:6650] Received 
cmd LOOKUP_RESPONSE
   11:10:12.064 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.client.impl.ClientCnx - Received Broker lookup response: 
Connect
   11:10:12.065 [pulsar-client-io-2-2] INFO 
org.apache.pulsar.client.impl.ConnectionPool - [[id: 0x1584bf83, 
L:/xx.16.10.82:10347 - R:/xx.16.200.96:6650]] Connected to server
   11:10:12.065 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.common.protocol.PulsarHandler - [[id: 0x1584bf83, 
L:/xx.16.10.82:10347 - R:/xx.16.200.96:6650]] Scheduling keep-alive task every 
30 s
   11:10:12.065 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.client.impl.ClientCnx - [id: 0x1584bf83, L:/xx.16.10.82:10347 
- R:/xx.16.200.96:6650] Connected to broker
   11:10:12.065 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.client.impl.ClientCnx - Complete: true
   11:10:12.067 [pulsar-client-io-2-4] DEBUG 
org.apache.pulsar.common.protocol.PulsarDecoder - [/xx.16.200.102:6650] 
Received cmd CONNECTED
   11:10:12.067 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.common.protocol.PulsarDecoder - [/xx.16.200.96:6650] Received 
cmd CONNECTED
   11:10:12.067 [pulsar-client-io-2-4] DEBUG 
org.apache.pulsar.client.impl.ClientCnx - [id: 0xc39b56e0, L:/xx.16.10.82:10346 
- R:/xx.16.200.102:6650] Connection has max message size setting, replace old 
frameDecoder with server frame size 5242880
   11:10:12.067 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.client.impl.ClientCnx - [id: 0x1584bf83, L:/xx.16.10.82:10347 
- R:/xx.16.200.96:6650] Connection has max message size setting, replace old 
frameDecoder with server frame size 5242880
   11:10:12.067 [pulsar-client-io-2-4] DEBUG 
org.apache.pulsar.client.impl.ClientCnx - [id: 0xc39b56e0, L:/xx.16.10.82:10346 
- R:/xx.16.200.102:6650] Connection is ready
   11:10:12.067 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.client.impl.ClientCnx - [id: 0x1584bf83, L:/xx.16.10.82:10347 
- R:/xx.16.200.96:6650] Connection is ready
   11:10:12.067 [pulsar-client-io-2-4] DEBUG 
org.apache.pulsar.client.impl.ConnectionPool - [[id: 0xc39b56e0, 
L:/xx.16.10.82:10346 - R:/xx.16.200.102:6650]] Connection handshake completed
   11:10:12.067 [pulsar-client-io-2-4] INFO 
org.apache.pulsar.client.impl.TransactionMetaStoreHandler - Transaction meta 
handler with transaction coordinator id 15 connection opened.
   11:10:12.067 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.client.impl.ConnectionPool - [[id: 0x1584bf83, 
L:/xx.16.10.82:10347 - R:/xx.16.200.96:6650]] Connection handshake completed
   11:10:12.067 [pulsar-client-io-2-2] INFO 
org.apache.pulsar.client.impl.TransactionMetaStoreHandler - Transaction meta 
handler with transaction coordinator id 13 connection opened.
   11:10:12.067 [pulsar-client-io-2-4] INFO 
org.apache.pulsar.client.impl.TransactionMetaStoreHandler - Transaction meta 
handler with transaction coordinator id 11 connection opened.
   11:10:12.068 [pulsar-client-io-2-4] INFO 
org.apache.pulsar.client.impl.TransactionMetaStoreHandler - Transaction meta 
handler with transaction coordinator id 8 connection opened.
   11:10:12.068 [pulsar-client-io-2-2] INFO 
org.apache.pulsar.client.impl.TransactionMetaStoreHandler - Transaction meta 
handler with transaction coordinator id 12 connection opened.
   11:10:12.068 [pulsar-client-io-2-4] INFO 
org.apache.pulsar.client.impl.TransactionMetaStoreHandler - Transaction meta 
handler with transaction coordinator id 7 connection opened.
   11:10:12.068 [pulsar-client-io-2-4] INFO 
org.apache.pulsar.client.impl.TransactionMetaStoreHandler - Transaction meta 
handler with transaction coordinator id 4 connection opened.
   11:10:12.068 [pulsar-client-io-2-4] INFO 
org.apache.pulsar.client.impl.TransactionMetaStoreHandler - Transaction meta 
handler with transaction coordinator id 3 connection opened.
   11:10:12.068 [pulsar-client-io-2-4] INFO 
org.apache.pulsar.client.impl.TransactionMetaStoreHandler - Transaction meta 
handler with transaction coordinator id 0 connection opened.
   11:10:12.069 [pulsar-cli-init-1-1] INFO 
com.wmfxly.pulsar.DemoPulsarClientInitUltimate - pulsar client init success
   11:10:16.141 [main] INFO org.apache.pulsar.client.impl.PulsarClientImpl - 
Client closing. URL: pulsar://xx.xx.xx.xx:6650
   11:10:16.143 [pulsar-client-io-2-4] DEBUG 
org.apache.pulsar.client.impl.ConnectionPool - Removing closed connection from 
pool: AbstractChannel$CloseFuture@60f26544(success)
   11:10:16.143 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.client.impl.ConnectionPool - Removing closed connection from 
pool: AbstractChannel$CloseFuture@636fa126(success)
   11:10:16.144 [pulsar-client-io-2-4] INFO 
org.apache.pulsar.client.impl.ClientCnx - [id: 0xc39b56e0, L:/xx.16.10.82:10346 
! R:/xx.16.200.102:6650] Disconnected
   11:10:16.144 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.client.impl.ConnectionPool - Removing closed connection from 
pool: AbstractChannel$CloseFuture@43c7baa1(success)
   11:10:16.145 [pulsar-client-io-2-2] INFO 
org.apache.pulsar.client.impl.ClientCnx - [id: 0x8adaadde, L:/xx.16.10.82:10345 
! R:/xx.xx.xx.xx:6650] Disconnected
   11:10:16.151 [pulsar-client-io-2-4] INFO 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-0] 
[Transaction meta store handler [0]] Closed connection [id: 0xc39b56e0, 
L:/xx.16.10.82:10346 ! R:/xx.16.200.102:6650] -- Will try again in 0.1 s
   11:10:16.151 [pulsar-client-io-2-2] INFO 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-9] 
[Transaction meta store handler [9]] Closed connection [id: 0x8adaadde, 
L:/xx.16.10.82:10345 ! R:/xx.xx.xx.xx:6650] -- Will try again in 0.1 s
   11:10:16.152 [pulsar-client-io-2-2] INFO 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-1] 
[Transaction meta store handler [1]] Closed connection [id: 0x8adaadde, 
L:/xx.16.10.82:10345 ! R:/xx.xx.xx.xx:6650] -- Will try again in 0.1 s
   11:10:16.152 [pulsar-client-io-2-4] INFO 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-4] 
[Transaction meta store handler [4]] Closed connection [id: 0xc39b56e0, 
L:/xx.16.10.82:10346 ! R:/xx.16.200.102:6650] -- Will try again in 0.1 s
   11:10:16.153 [pulsar-client-io-2-4] INFO 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-8] 
[Transaction meta store handler [8]] Closed connection [id: 0xc39b56e0, 
L:/xx.16.10.82:10346 ! R:/xx.16.200.102:6650] -- Will try again in 0.1 s
   11:10:16.153 [pulsar-client-io-2-2] INFO 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-5] 
[Transaction meta store handler [5]] Closed connection [id: 0x8adaadde, 
L:/xx.16.10.82:10345 ! R:/xx.xx.xx.xx:6650] -- Will try again in 0.1 s
   11:10:16.153 [pulsar-client-io-2-4] INFO 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-15] 
[Transaction meta store handler [15]] Closed connection [id: 0xc39b56e0, 
L:/xx.16.10.82:10346 ! R:/xx.16.200.102:6650] -- Will try again in 0.1 s
   11:10:16.153 [pulsar-client-io-2-2] INFO 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-14] 
[Transaction meta store handler [14]] Closed connection [id: 0x8adaadde, 
L:/xx.16.10.82:10345 ! R:/xx.xx.xx.xx:6650] -- Will try again in 0.1 s
   11:10:16.153 [pulsar-client-io-2-4] INFO 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-3] 
[Transaction meta store handler [3]] Closed connection [id: 0xc39b56e0, 
L:/xx.16.10.82:10346 ! R:/xx.16.200.102:6650] -- Will try again in 0.1 s
   11:10:16.153 [pulsar-client-io-2-2] INFO 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-2] 
[Transaction meta store handler [2]] Closed connection [id: 0x8adaadde, 
L:/xx.16.10.82:10345 ! R:/xx.xx.xx.xx:6650] -- Will try again in 0.1 s
   11:10:16.153 [pulsar-client-io-2-4] INFO 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-11] 
[Transaction meta store handler [11]] Closed connection [id: 0xc39b56e0, 
L:/xx.16.10.82:10346 ! R:/xx.16.200.102:6650] -- Will try again in 0.1 s
   11:10:16.153 [pulsar-client-io-2-2] INFO 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-10] 
[Transaction meta store handler [10]] Closed connection [id: 0x8adaadde, 
L:/xx.16.10.82:10345 ! R:/xx.xx.xx.xx:6650] -- Will try again in 0.1 s
   11:10:16.153 [pulsar-client-io-2-4] INFO 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-7] 
[Transaction meta store handler [7]] Closed connection [id: 0xc39b56e0, 
L:/xx.16.10.82:10346 ! R:/xx.16.200.102:6650] -- Will try again in 0.1 s
   11:10:16.153 [pulsar-client-io-2-2] INFO 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-6] 
[Transaction meta store handler [6]] Closed connection [id: 0x8adaadde, 
L:/xx.16.10.82:10345 ! R:/xx.xx.xx.xx:6650] -- Will try again in 0.1 s
   11:10:16.153 [pulsar-client-io-2-2] INFO 
org.apache.pulsar.client.impl.ClientCnx - [id: 0x1584bf83, L:/xx.16.10.82:10347 
! R:/xx.16.200.96:6650] Disconnected
   11:10:16.153 [pulsar-client-io-2-2] INFO 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-13] 
[Transaction meta store handler [13]] Closed connection [id: 0x1584bf83, 
L:/xx.16.10.82:10347 ! R:/xx.16.200.96:6650] -- Will try again in 0.1 s
   11:10:16.153 [pulsar-client-io-2-2] INFO 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-12] 
[Transaction meta store handler [12]] Closed connection [id: 0x1584bf83, 
L:/xx.16.10.82:10347 ! R:/xx.16.200.96:6650] -- Will try again in 0.1 s
   11:10:16.254 [pulsar-timer-18-1] INFO 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-9] 
[Transaction meta store handler [9]] Reconnecting after timeout
   11:10:16.254 [pulsar-timer-18-1] DEBUG 
org.apache.pulsar.client.impl.ConnectionPool - Connection for xx.xx.xx.xx:6650 
not found in cache
   11:10:16.254 [pulsar-timer-18-1] INFO 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-0] 
[Transaction meta store handler [0]] Reconnecting after timeout
   11:10:16.254 [pulsar-timer-18-1] INFO 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-1] 
[Transaction meta store handler [1]] Reconnecting after timeout
   11:10:16.254 [pulsar-timer-18-1] INFO 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-4] 
[Transaction meta store handler [4]] Reconnecting after timeout
   11:10:16.254 [pulsar-timer-18-1] INFO 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-8] 
[Transaction meta store handler [8]] Reconnecting after timeout
   11:10:16.254 [pulsar-timer-18-1] INFO 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-5] 
[Transaction meta store handler [5]] Reconnecting after timeout
   11:10:16.254 [pulsar-timer-18-1] INFO 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-15] 
[Transaction meta store handler [15]] Reconnecting after timeout
   11:10:16.254 [pulsar-timer-18-1] INFO 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-14] 
[Transaction meta store handler [14]] Reconnecting after timeout
   11:10:16.254 [pulsar-timer-18-1] INFO 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-3] 
[Transaction meta store handler [3]] Reconnecting after timeout
   11:10:16.254 [pulsar-timer-18-1] INFO 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-2] 
[Transaction meta store handler [2]] Reconnecting after timeout
   11:10:16.255 [pulsar-timer-18-1] INFO 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-11] 
[Transaction meta store handler [11]] Reconnecting after timeout
   11:10:16.255 [pulsar-timer-18-1] INFO 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-10] 
[Transaction meta store handler [10]] Reconnecting after timeout
   11:10:16.255 [pulsar-timer-18-1] INFO 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-7] 
[Transaction meta store handler [7]] Reconnecting after timeout
   11:10:16.255 [pulsar-timer-18-1] INFO 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-6] 
[Transaction meta store handler [6]] Reconnecting after timeout
   11:10:16.255 [pulsar-timer-18-1] INFO 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-13] 
[Transaction meta store handler [13]] Reconnecting after timeout
   11:10:16.255 [pulsar-timer-18-1] INFO 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-12] 
[Transaction meta store handler [12]] Reconnecting after timeout
   11:10:16.345 [pulsar-client-io-2-1] DEBUG 
org.apache.pulsar.shade.io.netty.channel.nio.NioEventLoop - Selector.select() 
returned prematurely 3 times in a row for Selector 
org.apache.pulsar.shade.io.netty.channel.nio.SelectedSelectionKeySetSelector@360fa1ca.
   11:10:16.355 [pulsar-client-io-2-4] DEBUG 
org.apache.pulsar.shade.io.netty.channel.nio.NioEventLoop - Selector.select() 
returned prematurely 3 times in a row for Selector 
org.apache.pulsar.shade.io.netty.channel.nio.SelectedSelectionKeySetSelector@5ac84ccd.
   11:10:16.445 [pulsar-client-io-2-1] WARN 
org.apache.pulsar.client.impl.ConnectionPool - Failed to open connection to 
xx.xx.xx.xx:6650 : java.lang.IllegalStateException: executor not accepting a 
task
   11:10:16.445 [pulsar-client-io-2-1] WARN 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-12] 
[Transaction meta store handler [12]] Error connecting to broker: 
org.apache.pulsar.client.api.PulsarClientException: 
java.util.concurrent.CompletionException: java.lang.IllegalStateException: 
executor not accepting a task
   11:10:16.448 [pulsar-client-io-2-1] ERROR 
org.apache.pulsar.client.impl.TransactionMetaStoreHandler - Transaction meta 
handler with transaction coordinator id 12 connection failed.
   org.apache.pulsar.client.api.PulsarClientException: 
java.util.concurrent.CompletionException: java.lang.IllegalStateException: 
executor not accepting a task
        at 
org.apache.pulsar.client.impl.ConnectionPool.lambda$createConnection$9(ConnectionPool.java:216)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472)
        at 
org.apache.pulsar.shade.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
        at 
org.apache.pulsar.shade.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.lang.Thread.run(Thread.java:745)
   Caused by: java.util.concurrent.CompletionException: 
java.lang.IllegalStateException: executor not accepting a task
        at 
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
        at 
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
        at 
java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:647)
        at 
java.util.concurrent.CompletableFuture$UniAccept.tryFire$$$capture(CompletableFuture.java:632)
        at 
java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java)
        at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
        at 
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
        at 
org.apache.pulsar.common.util.netty.ChannelFutures.lambda$toCompletableFuture$0(ChannelFutures.java:58)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:609)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setFailure(DefaultPromise.java:109)
        at 
org.apache.pulsar.shade.io.netty.channel.DefaultChannelPromise.setFailure(DefaultChannelPromise.java:89)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:197)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:46)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:180)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:166)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)
        at 
org.apache.pulsar.shade.io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:1012)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:516)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:429)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:486)
        ... 7 common frames omitted
   Caused by: java.lang.IllegalStateException: executor not accepting a task
        at 
org.apache.pulsar.shade.io.netty.resolver.AddressResolverGroup.getResolver(AddressResolverGroup.java:61)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:194)
        ... 21 common frames omitted
   11:10:16.448 [pulsar-client-io-2-1] WARN 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-13] 
[Transaction meta store handler [13]] Error connecting to broker: 
org.apache.pulsar.client.api.PulsarClientException: 
java.util.concurrent.CompletionException: java.lang.IllegalStateException: 
executor not accepting a task
   11:10:16.448 [pulsar-client-io-2-1] ERROR 
org.apache.pulsar.client.impl.TransactionMetaStoreHandler - Transaction meta 
handler with transaction coordinator id 13 connection failed.
   org.apache.pulsar.client.api.PulsarClientException: 
java.util.concurrent.CompletionException: java.lang.IllegalStateException: 
executor not accepting a task
        at 
org.apache.pulsar.client.impl.ConnectionPool.lambda$createConnection$9(ConnectionPool.java:216)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472)
        at 
org.apache.pulsar.shade.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
        at 
org.apache.pulsar.shade.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.lang.Thread.run(Thread.java:745)
   Caused by: java.util.concurrent.CompletionException: 
java.lang.IllegalStateException: executor not accepting a task
        at 
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
        at 
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
        at 
java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:647)
        at 
java.util.concurrent.CompletableFuture$UniAccept.tryFire$$$capture(CompletableFuture.java:632)
        at 
java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java)
        at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
        at 
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
        at 
org.apache.pulsar.common.util.netty.ChannelFutures.lambda$toCompletableFuture$0(ChannelFutures.java:58)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:609)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setFailure(DefaultPromise.java:109)
        at 
org.apache.pulsar.shade.io.netty.channel.DefaultChannelPromise.setFailure(DefaultChannelPromise.java:89)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:197)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:46)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:180)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:166)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)
        at 
org.apache.pulsar.shade.io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:1012)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:516)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:429)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:486)
        ... 7 common frames omitted
   Caused by: java.lang.IllegalStateException: executor not accepting a task
        at 
org.apache.pulsar.shade.io.netty.resolver.AddressResolverGroup.getResolver(AddressResolverGroup.java:61)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:194)
        ... 21 common frames omitted
   11:10:16.448 [pulsar-client-io-2-1] WARN 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-6] 
[Transaction meta store handler [6]] Error connecting to broker: 
org.apache.pulsar.client.api.PulsarClientException: 
java.util.concurrent.CompletionException: java.lang.IllegalStateException: 
executor not accepting a task
   11:10:16.448 [pulsar-client-io-2-1] ERROR 
org.apache.pulsar.client.impl.TransactionMetaStoreHandler - Transaction meta 
handler with transaction coordinator id 6 connection failed.
   org.apache.pulsar.client.api.PulsarClientException: 
java.util.concurrent.CompletionException: java.lang.IllegalStateException: 
executor not accepting a task
        at 
org.apache.pulsar.client.impl.ConnectionPool.lambda$createConnection$9(ConnectionPool.java:216)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472)
        at 
org.apache.pulsar.shade.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
        at 
org.apache.pulsar.shade.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.lang.Thread.run(Thread.java:745)
   Caused by: java.util.concurrent.CompletionException: 
java.lang.IllegalStateException: executor not accepting a task
        at 
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
        at 
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
        at 
java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:647)
        at 
java.util.concurrent.CompletableFuture$UniAccept.tryFire$$$capture(CompletableFuture.java:632)
        at 
java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java)
        at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
        at 
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
        at 
org.apache.pulsar.common.util.netty.ChannelFutures.lambda$toCompletableFuture$0(ChannelFutures.java:58)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:609)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setFailure(DefaultPromise.java:109)
        at 
org.apache.pulsar.shade.io.netty.channel.DefaultChannelPromise.setFailure(DefaultChannelPromise.java:89)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:197)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:46)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:180)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:166)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)
        at 
org.apache.pulsar.shade.io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:1012)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:516)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:429)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:486)
        ... 7 common frames omitted
   Caused by: java.lang.IllegalStateException: executor not accepting a task
        at 
org.apache.pulsar.shade.io.netty.resolver.AddressResolverGroup.getResolver(AddressResolverGroup.java:61)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:194)
        ... 21 common frames omitted
   11:10:16.448 [pulsar-client-io-2-1] WARN 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-7] 
[Transaction meta store handler [7]] Error connecting to broker: 
org.apache.pulsar.client.api.PulsarClientException: 
java.util.concurrent.CompletionException: java.lang.IllegalStateException: 
executor not accepting a task
   11:10:16.449 [pulsar-client-io-2-1] ERROR 
org.apache.pulsar.client.impl.TransactionMetaStoreHandler - Transaction meta 
handler with transaction coordinator id 7 connection failed.
   org.apache.pulsar.client.api.PulsarClientException: 
java.util.concurrent.CompletionException: java.lang.IllegalStateException: 
executor not accepting a task
        at 
org.apache.pulsar.client.impl.ConnectionPool.lambda$createConnection$9(ConnectionPool.java:216)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472)
        at 
org.apache.pulsar.shade.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
        at 
org.apache.pulsar.shade.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.lang.Thread.run(Thread.java:745)
   Caused by: java.util.concurrent.CompletionException: 
java.lang.IllegalStateException: executor not accepting a task
        at 
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
        at 
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
        at 
java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:647)
        at 
java.util.concurrent.CompletableFuture$UniAccept.tryFire$$$capture(CompletableFuture.java:632)
        at 
java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java)
        at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
        at 
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
        at 
org.apache.pulsar.common.util.netty.ChannelFutures.lambda$toCompletableFuture$0(ChannelFutures.java:58)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:609)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setFailure(DefaultPromise.java:109)
        at 
org.apache.pulsar.shade.io.netty.channel.DefaultChannelPromise.setFailure(DefaultChannelPromise.java:89)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:197)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:46)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:180)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:166)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)
        at 
org.apache.pulsar.shade.io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:1012)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:516)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:429)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:486)
        ... 7 common frames omitted
   Caused by: java.lang.IllegalStateException: executor not accepting a task
        at 
org.apache.pulsar.shade.io.netty.resolver.AddressResolverGroup.getResolver(AddressResolverGroup.java:61)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:194)
        ... 21 common frames omitted
   11:10:16.449 [pulsar-client-io-2-1] WARN 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-10] 
[Transaction meta store handler [10]] Error connecting to broker: 
org.apache.pulsar.client.api.PulsarClientException: 
java.util.concurrent.CompletionException: java.lang.IllegalStateException: 
executor not accepting a task
   11:10:16.449 [pulsar-client-io-2-1] ERROR 
org.apache.pulsar.client.impl.TransactionMetaStoreHandler - Transaction meta 
handler with transaction coordinator id 10 connection failed.
   org.apache.pulsar.client.api.PulsarClientException: 
java.util.concurrent.CompletionException: java.lang.IllegalStateException: 
executor not accepting a task
        at 
org.apache.pulsar.client.impl.ConnectionPool.lambda$createConnection$9(ConnectionPool.java:216)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472)
        at 
org.apache.pulsar.shade.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
        at 
org.apache.pulsar.shade.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.lang.Thread.run(Thread.java:745)
   Caused by: java.util.concurrent.CompletionException: 
java.lang.IllegalStateException: executor not accepting a task
        at 
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
        at 
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
        at 
java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:647)
        at 
java.util.concurrent.CompletableFuture$UniAccept.tryFire$$$capture(CompletableFuture.java:632)
        at 
java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java)
        at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
        at 
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
        at 
org.apache.pulsar.common.util.netty.ChannelFutures.lambda$toCompletableFuture$0(ChannelFutures.java:58)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:609)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setFailure(DefaultPromise.java:109)
        at 
org.apache.pulsar.shade.io.netty.channel.DefaultChannelPromise.setFailure(DefaultChannelPromise.java:89)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:197)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:46)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:180)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:166)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)
        at 
org.apache.pulsar.shade.io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:1012)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:516)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:429)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:486)
        ... 7 common frames omitted
   Caused by: java.lang.IllegalStateException: executor not accepting a task
        at 
org.apache.pulsar.shade.io.netty.resolver.AddressResolverGroup.getResolver(AddressResolverGroup.java:61)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:194)
        ... 21 common frames omitted
   11:10:16.449 [pulsar-client-io-2-1] WARN 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-11] 
[Transaction meta store handler [11]] Error connecting to broker: 
org.apache.pulsar.client.api.PulsarClientException: 
java.util.concurrent.CompletionException: java.lang.IllegalStateException: 
executor not accepting a task
   11:10:16.449 [pulsar-client-io-2-1] ERROR 
org.apache.pulsar.client.impl.TransactionMetaStoreHandler - Transaction meta 
handler with transaction coordinator id 11 connection failed.
   org.apache.pulsar.client.api.PulsarClientException: 
java.util.concurrent.CompletionException: java.lang.IllegalStateException: 
executor not accepting a task
        at 
org.apache.pulsar.client.impl.ConnectionPool.lambda$createConnection$9(ConnectionPool.java:216)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472)
        at 
org.apache.pulsar.shade.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
        at 
org.apache.pulsar.shade.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.lang.Thread.run(Thread.java:745)
   Caused by: java.util.concurrent.CompletionException: 
java.lang.IllegalStateException: executor not accepting a task
        at 
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
        at 
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
        at 
java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:647)
        at 
java.util.concurrent.CompletableFuture$UniAccept.tryFire$$$capture(CompletableFuture.java:632)
        at 
java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java)
        at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
        at 
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
        at 
org.apache.pulsar.common.util.netty.ChannelFutures.lambda$toCompletableFuture$0(ChannelFutures.java:58)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:609)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setFailure(DefaultPromise.java:109)
        at 
org.apache.pulsar.shade.io.netty.channel.DefaultChannelPromise.setFailure(DefaultChannelPromise.java:89)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:197)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:46)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:180)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:166)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)
        at 
org.apache.pulsar.shade.io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:1012)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:516)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:429)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:486)
        ... 7 common frames omitted
   Caused by: java.lang.IllegalStateException: executor not accepting a task
        at 
org.apache.pulsar.shade.io.netty.resolver.AddressResolverGroup.getResolver(AddressResolverGroup.java:61)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:194)
        ... 21 common frames omitted
   11:10:16.449 [pulsar-client-io-2-1] WARN 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-2] 
[Transaction meta store handler [2]] Error connecting to broker: 
org.apache.pulsar.client.api.PulsarClientException: 
java.util.concurrent.CompletionException: java.lang.IllegalStateException: 
executor not accepting a task
   11:10:16.449 [pulsar-client-io-2-1] ERROR 
org.apache.pulsar.client.impl.TransactionMetaStoreHandler - Transaction meta 
handler with transaction coordinator id 2 connection failed.
   org.apache.pulsar.client.api.PulsarClientException: 
java.util.concurrent.CompletionException: java.lang.IllegalStateException: 
executor not accepting a task
        at 
org.apache.pulsar.client.impl.ConnectionPool.lambda$createConnection$9(ConnectionPool.java:216)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472)
        at 
org.apache.pulsar.shade.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
        at 
org.apache.pulsar.shade.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.lang.Thread.run(Thread.java:745)
   Caused by: java.util.concurrent.CompletionException: 
java.lang.IllegalStateException: executor not accepting a task
        at 
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
        at 
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
        at 
java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:647)
        at 
java.util.concurrent.CompletableFuture$UniAccept.tryFire$$$capture(CompletableFuture.java:632)
        at 
java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java)
        at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
        at 
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
        at 
org.apache.pulsar.common.util.netty.ChannelFutures.lambda$toCompletableFuture$0(ChannelFutures.java:58)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:609)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setFailure(DefaultPromise.java:109)
        at 
org.apache.pulsar.shade.io.netty.channel.DefaultChannelPromise.setFailure(DefaultChannelPromise.java:89)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:197)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:46)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:180)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:166)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)
        at 
org.apache.pulsar.shade.io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:1012)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:516)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:429)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:486)
        ... 7 common frames omitted
   Caused by: java.lang.IllegalStateException: executor not accepting a task
        at 
org.apache.pulsar.shade.io.netty.resolver.AddressResolverGroup.getResolver(AddressResolverGroup.java:61)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:194)
        ... 21 common frames omitted
   11:10:16.450 [pulsar-client-io-2-1] WARN 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-3] 
[Transaction meta store handler [3]] Error connecting to broker: 
org.apache.pulsar.client.api.PulsarClientException: 
java.util.concurrent.CompletionException: java.lang.IllegalStateException: 
executor not accepting a task
   11:10:16.450 [pulsar-client-io-2-1] ERROR 
org.apache.pulsar.client.impl.TransactionMetaStoreHandler - Transaction meta 
handler with transaction coordinator id 3 connection failed.
   org.apache.pulsar.client.api.PulsarClientException: 
java.util.concurrent.CompletionException: java.lang.IllegalStateException: 
executor not accepting a task
        at 
org.apache.pulsar.client.impl.ConnectionPool.lambda$createConnection$9(ConnectionPool.java:216)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472)
        at 
org.apache.pulsar.shade.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
        at 
org.apache.pulsar.shade.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.lang.Thread.run(Thread.java:745)
   Caused by: java.util.concurrent.CompletionException: 
java.lang.IllegalStateException: executor not accepting a task
        at 
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
        at 
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
        at 
java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:647)
        at 
java.util.concurrent.CompletableFuture$UniAccept.tryFire$$$capture(CompletableFuture.java:632)
        at 
java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java)
        at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
        at 
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
        at 
org.apache.pulsar.common.util.netty.ChannelFutures.lambda$toCompletableFuture$0(ChannelFutures.java:58)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:609)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setFailure(DefaultPromise.java:109)
        at 
org.apache.pulsar.shade.io.netty.channel.DefaultChannelPromise.setFailure(DefaultChannelPromise.java:89)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:197)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:46)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:180)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:166)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)
        at 
org.apache.pulsar.shade.io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:1012)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:516)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:429)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:486)
        ... 7 common frames omitted
   Caused by: java.lang.IllegalStateException: executor not accepting a task
        at 
org.apache.pulsar.shade.io.netty.resolver.AddressResolverGroup.getResolver(AddressResolverGroup.java:61)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:194)
        ... 21 common frames omitted
   11:10:16.450 [pulsar-client-io-2-1] WARN 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-14] 
[Transaction meta store handler [14]] Error connecting to broker: 
org.apache.pulsar.client.api.PulsarClientException: 
java.util.concurrent.CompletionException: java.lang.IllegalStateException: 
executor not accepting a task
   11:10:16.450 [pulsar-client-io-2-1] ERROR 
org.apache.pulsar.client.impl.TransactionMetaStoreHandler - Transaction meta 
handler with transaction coordinator id 14 connection failed.
   org.apache.pulsar.client.api.PulsarClientException: 
java.util.concurrent.CompletionException: java.lang.IllegalStateException: 
executor not accepting a task
        at 
org.apache.pulsar.client.impl.ConnectionPool.lambda$createConnection$9(ConnectionPool.java:216)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472)
        at 
org.apache.pulsar.shade.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
        at 
org.apache.pulsar.shade.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.lang.Thread.run(Thread.java:745)
   Caused by: java.util.concurrent.CompletionException: 
java.lang.IllegalStateException: executor not accepting a task
        at 
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
        at 
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
        at 
java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:647)
        at 
java.util.concurrent.CompletableFuture$UniAccept.tryFire$$$capture(CompletableFuture.java:632)
        at 
java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java)
        at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
        at 
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
        at 
org.apache.pulsar.common.util.netty.ChannelFutures.lambda$toCompletableFuture$0(ChannelFutures.java:58)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:609)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setFailure(DefaultPromise.java:109)
        at 
org.apache.pulsar.shade.io.netty.channel.DefaultChannelPromise.setFailure(DefaultChannelPromise.java:89)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:197)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:46)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:180)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:166)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)
        at 
org.apache.pulsar.shade.io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:1012)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:516)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:429)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:486)
        ... 7 common frames omitted
   Caused by: java.lang.IllegalStateException: executor not accepting a task
        at 
org.apache.pulsar.shade.io.netty.resolver.AddressResolverGroup.getResolver(AddressResolverGroup.java:61)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:194)
        ... 21 common frames omitted
   11:10:16.450 [pulsar-client-io-2-1] WARN 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-15] 
[Transaction meta store handler [15]] Error connecting to broker: 
org.apache.pulsar.client.api.PulsarClientException: 
java.util.concurrent.CompletionException: java.lang.IllegalStateException: 
executor not accepting a task
   11:10:16.450 [pulsar-client-io-2-1] ERROR 
org.apache.pulsar.client.impl.TransactionMetaStoreHandler - Transaction meta 
handler with transaction coordinator id 15 connection failed.
   org.apache.pulsar.client.api.PulsarClientException: 
java.util.concurrent.CompletionException: java.lang.IllegalStateException: 
executor not accepting a task
        at 
org.apache.pulsar.client.impl.ConnectionPool.lambda$createConnection$9(ConnectionPool.java:216)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472)
        at 
org.apache.pulsar.shade.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
        at 
org.apache.pulsar.shade.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.lang.Thread.run(Thread.java:745)
   Caused by: java.util.concurrent.CompletionException: 
java.lang.IllegalStateException: executor not accepting a task
        at 
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
        at 
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
        at 
java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:647)
        at 
java.util.concurrent.CompletableFuture$UniAccept.tryFire$$$capture(CompletableFuture.java:632)
        at 
java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java)
        at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
        at 
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
        at 
org.apache.pulsar.common.util.netty.ChannelFutures.lambda$toCompletableFuture$0(ChannelFutures.java:58)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:609)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setFailure(DefaultPromise.java:109)
        at 
org.apache.pulsar.shade.io.netty.channel.DefaultChannelPromise.setFailure(DefaultChannelPromise.java:89)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:197)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:46)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:180)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:166)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)
        at 
org.apache.pulsar.shade.io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:1012)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:516)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:429)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:486)
        ... 7 common frames omitted
   Caused by: java.lang.IllegalStateException: executor not accepting a task
        at 
org.apache.pulsar.shade.io.netty.resolver.AddressResolverGroup.getResolver(AddressResolverGroup.java:61)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:194)
        ... 21 common frames omitted
   11:10:16.450 [pulsar-client-io-2-1] WARN 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-5] 
[Transaction meta store handler [5]] Error connecting to broker: 
org.apache.pulsar.client.api.PulsarClientException: 
java.util.concurrent.CompletionException: java.lang.IllegalStateException: 
executor not accepting a task
   11:10:16.450 [pulsar-client-io-2-1] ERROR 
org.apache.pulsar.client.impl.TransactionMetaStoreHandler - Transaction meta 
handler with transaction coordinator id 5 connection failed.
   org.apache.pulsar.client.api.PulsarClientException: 
java.util.concurrent.CompletionException: java.lang.IllegalStateException: 
executor not accepting a task
        at 
org.apache.pulsar.client.impl.ConnectionPool.lambda$createConnection$9(ConnectionPool.java:216)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472)
        at 
org.apache.pulsar.shade.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
        at 
org.apache.pulsar.shade.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.lang.Thread.run(Thread.java:745)
   Caused by: java.util.concurrent.CompletionException: 
java.lang.IllegalStateException: executor not accepting a task
        at 
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
        at 
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
        at 
java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:647)
        at 
java.util.concurrent.CompletableFuture$UniAccept.tryFire$$$capture(CompletableFuture.java:632)
        at 
java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java)
        at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
        at 
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
        at 
org.apache.pulsar.common.util.netty.ChannelFutures.lambda$toCompletableFuture$0(ChannelFutures.java:58)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:609)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setFailure(DefaultPromise.java:109)
        at 
org.apache.pulsar.shade.io.netty.channel.DefaultChannelPromise.setFailure(DefaultChannelPromise.java:89)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:197)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:46)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:180)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:166)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)
        at 
org.apache.pulsar.shade.io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:1012)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:516)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:429)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:486)
        ... 7 common frames omitted
   Caused by: java.lang.IllegalStateException: executor not accepting a task
        at 
org.apache.pulsar.shade.io.netty.resolver.AddressResolverGroup.getResolver(AddressResolverGroup.java:61)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:194)
        ... 21 common frames omitted
   11:10:16.450 [pulsar-client-io-2-1] WARN 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-8] 
[Transaction meta store handler [8]] Error connecting to broker: 
org.apache.pulsar.client.api.PulsarClientException: 
java.util.concurrent.CompletionException: java.lang.IllegalStateException: 
executor not accepting a task
   11:10:16.450 [pulsar-client-io-2-1] ERROR 
org.apache.pulsar.client.impl.TransactionMetaStoreHandler - Transaction meta 
handler with transaction coordinator id 8 connection failed.
   org.apache.pulsar.client.api.PulsarClientException: 
java.util.concurrent.CompletionException: java.lang.IllegalStateException: 
executor not accepting a task
        at 
org.apache.pulsar.client.impl.ConnectionPool.lambda$createConnection$9(ConnectionPool.java:216)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472)
        at 
org.apache.pulsar.shade.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
        at 
org.apache.pulsar.shade.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.lang.Thread.run(Thread.java:745)
   Caused by: java.util.concurrent.CompletionException: 
java.lang.IllegalStateException: executor not accepting a task
        at 
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
        at 
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
        at 
java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:647)
        at 
java.util.concurrent.CompletableFuture$UniAccept.tryFire$$$capture(CompletableFuture.java:632)
        at 
java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java)
        at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
        at 
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
        at 
org.apache.pulsar.common.util.netty.ChannelFutures.lambda$toCompletableFuture$0(ChannelFutures.java:58)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:609)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setFailure(DefaultPromise.java:109)
        at 
org.apache.pulsar.shade.io.netty.channel.DefaultChannelPromise.setFailure(DefaultChannelPromise.java:89)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:197)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:46)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:180)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:166)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)
        at 
org.apache.pulsar.shade.io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:1012)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:516)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:429)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:486)
        ... 7 common frames omitted
   Caused by: java.lang.IllegalStateException: executor not accepting a task
        at 
org.apache.pulsar.shade.io.netty.resolver.AddressResolverGroup.getResolver(AddressResolverGroup.java:61)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:194)
        ... 21 common frames omitted
   11:10:16.450 [pulsar-client-io-2-1] WARN 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-4] 
[Transaction meta store handler [4]] Error connecting to broker: 
org.apache.pulsar.client.api.PulsarClientException: 
java.util.concurrent.CompletionException: java.lang.IllegalStateException: 
executor not accepting a task
   11:10:16.450 [pulsar-client-io-2-1] ERROR 
org.apache.pulsar.client.impl.TransactionMetaStoreHandler - Transaction meta 
handler with transaction coordinator id 4 connection failed.
   org.apache.pulsar.client.api.PulsarClientException: 
java.util.concurrent.CompletionException: java.lang.IllegalStateException: 
executor not accepting a task
        at 
org.apache.pulsar.client.impl.ConnectionPool.lambda$createConnection$9(ConnectionPool.java:216)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472)
        at 
org.apache.pulsar.shade.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
        at 
org.apache.pulsar.shade.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.lang.Thread.run(Thread.java:745)
   Caused by: java.util.concurrent.CompletionException: 
java.lang.IllegalStateException: executor not accepting a task
        at 
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
        at 
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
        at 
java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:647)
        at 
java.util.concurrent.CompletableFuture$UniAccept.tryFire$$$capture(CompletableFuture.java:632)
        at 
java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java)
        at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
        at 
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
        at 
org.apache.pulsar.common.util.netty.ChannelFutures.lambda$toCompletableFuture$0(ChannelFutures.java:58)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:609)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setFailure(DefaultPromise.java:109)
        at 
org.apache.pulsar.shade.io.netty.channel.DefaultChannelPromise.setFailure(DefaultChannelPromise.java:89)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:197)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:46)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:180)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:166)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)
        at 
org.apache.pulsar.shade.io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:1012)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:516)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:429)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:486)
        ... 7 common frames omitted
   Caused by: java.lang.IllegalStateException: executor not accepting a task
        at 
org.apache.pulsar.shade.io.netty.resolver.AddressResolverGroup.getResolver(AddressResolverGroup.java:61)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:194)
        ... 21 common frames omitted
   11:10:16.451 [pulsar-client-io-2-1] WARN 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-1] 
[Transaction meta store handler [1]] Error connecting to broker: 
org.apache.pulsar.client.api.PulsarClientException: 
java.util.concurrent.CompletionException: java.lang.IllegalStateException: 
executor not accepting a task
   11:10:16.451 [pulsar-client-io-2-1] ERROR 
org.apache.pulsar.client.impl.TransactionMetaStoreHandler - Transaction meta 
handler with transaction coordinator id 1 connection failed.
   org.apache.pulsar.client.api.PulsarClientException: 
java.util.concurrent.CompletionException: java.lang.IllegalStateException: 
executor not accepting a task
        at 
org.apache.pulsar.client.impl.ConnectionPool.lambda$createConnection$9(ConnectionPool.java:216)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472)
        at 
org.apache.pulsar.shade.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
        at 
org.apache.pulsar.shade.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.lang.Thread.run(Thread.java:745)
   Caused by: java.util.concurrent.CompletionException: 
java.lang.IllegalStateException: executor not accepting a task
        at 
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
        at 
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
        at 
java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:647)
        at 
java.util.concurrent.CompletableFuture$UniAccept.tryFire$$$capture(CompletableFuture.java:632)
        at 
java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java)
        at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
        at 
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
        at 
org.apache.pulsar.common.util.netty.ChannelFutures.lambda$toCompletableFuture$0(ChannelFutures.java:58)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:609)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setFailure(DefaultPromise.java:109)
        at 
org.apache.pulsar.shade.io.netty.channel.DefaultChannelPromise.setFailure(DefaultChannelPromise.java:89)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:197)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:46)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:180)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:166)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)
        at 
org.apache.pulsar.shade.io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:1012)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:516)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:429)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:486)
        ... 7 common frames omitted
   Caused by: java.lang.IllegalStateException: executor not accepting a task
        at 
org.apache.pulsar.shade.io.netty.resolver.AddressResolverGroup.getResolver(AddressResolverGroup.java:61)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:194)
        ... 21 common frames omitted
   11:10:16.451 [pulsar-client-io-2-1] WARN 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-0] 
[Transaction meta store handler [0]] Error connecting to broker: 
org.apache.pulsar.client.api.PulsarClientException: 
java.util.concurrent.CompletionException: java.lang.IllegalStateException: 
executor not accepting a task
   11:10:16.451 [pulsar-client-io-2-1] ERROR 
org.apache.pulsar.client.impl.TransactionMetaStoreHandler - Transaction meta 
handler with transaction coordinator id 0 connection failed.
   org.apache.pulsar.client.api.PulsarClientException: 
java.util.concurrent.CompletionException: java.lang.IllegalStateException: 
executor not accepting a task
        at 
org.apache.pulsar.client.impl.ConnectionPool.lambda$createConnection$9(ConnectionPool.java:216)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472)
        at 
org.apache.pulsar.shade.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
        at 
org.apache.pulsar.shade.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.lang.Thread.run(Thread.java:745)
   Caused by: java.util.concurrent.CompletionException: 
java.lang.IllegalStateException: executor not accepting a task
        at 
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
        at 
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
        at 
java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:647)
        at 
java.util.concurrent.CompletableFuture$UniAccept.tryFire$$$capture(CompletableFuture.java:632)
        at 
java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java)
        at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
        at 
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
        at 
org.apache.pulsar.common.util.netty.ChannelFutures.lambda$toCompletableFuture$0(ChannelFutures.java:58)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:609)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setFailure(DefaultPromise.java:109)
        at 
org.apache.pulsar.shade.io.netty.channel.DefaultChannelPromise.setFailure(DefaultChannelPromise.java:89)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:197)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:46)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:180)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:166)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)
        at 
org.apache.pulsar.shade.io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:1012)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:516)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:429)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:486)
        ... 7 common frames omitted
   Caused by: java.lang.IllegalStateException: executor not accepting a task
        at 
org.apache.pulsar.shade.io.netty.resolver.AddressResolverGroup.getResolver(AddressResolverGroup.java:61)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:194)
        ... 21 common frames omitted
   11:10:16.451 [pulsar-client-io-2-1] WARN 
org.apache.pulsar.client.impl.ConnectionHandler - 
[persistent://pulsar/system/transaction_coordinator_assign-partition-9] 
[Transaction meta store handler [9]] Error connecting to broker: 
org.apache.pulsar.client.api.PulsarClientException: 
java.util.concurrent.CompletionException: java.lang.IllegalStateException: 
executor not accepting a task
   11:10:16.451 [pulsar-client-io-2-1] ERROR 
org.apache.pulsar.client.impl.TransactionMetaStoreHandler - Transaction meta 
handler with transaction coordinator id 9 connection failed.
   org.apache.pulsar.client.api.PulsarClientException: 
java.util.concurrent.CompletionException: java.lang.IllegalStateException: 
executor not accepting a task
        at 
org.apache.pulsar.client.impl.ConnectionPool.lambda$createConnection$9(ConnectionPool.java:216)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472)
        at 
org.apache.pulsar.shade.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
        at 
org.apache.pulsar.shade.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
        at java.lang.Thread.run(Thread.java:745)
   Caused by: java.util.concurrent.CompletionException: 
java.lang.IllegalStateException: executor not accepting a task
        at 
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
        at 
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
        at 
java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:647)
        at 
java.util.concurrent.CompletableFuture$UniAccept.tryFire$$$capture(CompletableFuture.java:632)
        at 
java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java)
        at 
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
        at 
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
        at 
org.apache.pulsar.common.util.netty.ChannelFutures.lambda$toCompletableFuture$0(ChannelFutures.java:58)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:609)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setFailure(DefaultPromise.java:109)
        at 
org.apache.pulsar.shade.io.netty.channel.DefaultChannelPromise.setFailure(DefaultChannelPromise.java:89)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:197)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:46)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:180)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:166)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605)
        at 
org.apache.pulsar.shade.io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)
        at 
org.apache.pulsar.shade.io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:1012)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:516)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:429)
        at 
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:486)
        ... 7 common frames omitted
   Caused by: java.lang.IllegalStateException: executor not accepting a task
        at 
org.apache.pulsar.shade.io.netty.resolver.AddressResolverGroup.getResolver(AddressResolverGroup.java:61)
        at 
org.apache.pulsar.shade.io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:194)
        ... 21 common frames omitted
   11:10:18.167 [pulsar-client-io-2-2] DEBUG 
org.apache.pulsar.shade.io.netty.buffer.PoolThreadCache - Freed 6 thread-local 
buffer(s) from thread: pulsar-client-io-2-2
   11:10:18.374 [pulsar-client-io-2-4] DEBUG 
org.apache.pulsar.shade.io.netty.buffer.PoolThreadCache - Freed 2 thread-local 
buffer(s) from thread: pulsar-client-io-2-4
   Disconnected from the target VM, address: '127.0.0.1:11164', transport: 
'socket'
   
   Process finished with exit code 0
   
   
   
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

[GitHub] [pulsar] wmfxly opened a new issue #12682: Pulsar Transaction msg stop application throw executor not accepting a task

Reply via email to