You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2021/11/09 02:49:33 UTC
[GitHub] [pulsar] wmfxly opened a new issue #12682: Pulsar Transaction msg stop application throw executor not accepting a task
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: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] codelipenghui closed issue #12682: Pulsar Transaction msg stop application throw executor not accepting a task
Posted by GitBox <gi...@apache.org>.
codelipenghui closed issue #12682:
URL: https://github.com/apache/pulsar/issues/12682
--
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: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] congbobo184 edited a comment on issue #12682: Pulsar Transaction msg stop application throw executor not accepting a task
Posted by GitBox <gi...@apache.org>.
congbobo184 edited a comment on issue #12682:
URL: https://github.com/apache/pulsar/issues/12682#issuecomment-964718755
@wmfxly hi, https://github.com/apache/pulsar/pull/12689 will fix it. Tc client connect logic has been changed, I suggest you use 2.9.0. https://github.com/apache/pulsar/pull/12301
--
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: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] congbobo184 commented on issue #12682: Pulsar Transaction msg stop application throw executor not accepting a task
Posted by GitBox <gi...@apache.org>.
congbobo184 commented on issue #12682:
URL: https://github.com/apache/pulsar/issues/12682#issuecomment-964718755
@wmfxly https://github.com/apache/pulsar/pull/12689 will fix it. Tc client connect logic has been changed, I suggest you use 2.9.0. https://github.com/apache/pulsar/pull/12301
--
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: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org