2024-05-22 13:19:41 WARN BrokerFastFailureScheduledThread1 - broker jstack NettyEventExecutor TID: 74 STATE: TIMED_WAITING NettyEventExecutor sun.misc.Unsafe.park(Native Method) NettyEventExecutor java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) NettyEventExecutor java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) NettyEventExecutor java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467) NettyEventExecutor org.apache.rocketmq.remoting.netty.NettyRemotingAbstract$NettyEventExecutor.run(NettyRemotingAbstract.java:689) NettyEventExecutor java.lang.Thread.run(Thread.java:750) compactionSchedule_1 TID: 33 STATE: TIMED_WAITING compactionSchedule_1 sun.misc.Unsafe.park(Native Method) compactionSchedule_1 java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) compactionSchedule_1 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) compactionSchedule_1 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093) compactionSchedule_1 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) compactionSchedule_1 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) compactionSchedule_1 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) compactionSchedule_1 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) compactionSchedule_1 java.lang.Thread.run(Thread.java:750) ConsumerManageThread_23 TID: 158 STATE: WAITING ConsumerManageThread_23 sun.misc.Unsafe.defineClass(Native Method) ConsumerManageThread_23 sun.reflect.ClassDefiner.defineClass(ClassDefiner.java:63) ConsumerManageThread_23 sun.reflect.MethodAccessorGenerator$1.run(MethodAccessorGenerator.java:399) ConsumerManageThread_23 sun.reflect.MethodAccessorGenerator$1.run(MethodAccessorGenerator.java:394) ConsumerManageThread_23 java.security.AccessController.doPrivileged(Native Method) ConsumerManageThread_23 sun.reflect.MethodAccessorGenerator.generate(MethodAccessorGenerator.java:393) ConsumerManageThread_23 sun.reflect.MethodAccessorGenerator.generateConstructor(MethodAccessorGenerator.java:92) ConsumerManageThread_23 sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:55) ConsumerManageThread_23 sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) ConsumerManageThread_23 java.lang.reflect.Constructor.newInstance(Constructor.java:423) ConsumerManageThread_23 org.apache.rocketmq.remoting.protocol.RemotingCommand.createResponseCommand(RemotingCommand.java:159) ConsumerManageThread_23 org.apache.rocketmq.remoting.protocol.RemotingCommand.createResponseCommand(RemotingCommand.java:134) ConsumerManageThread_23 org.apache.rocketmq.broker.processor.ConsumerManageProcessor.updateConsumerOffset(ConsumerManageProcessor.java:148) ConsumerManageThread_23 org.apache.rocketmq.broker.processor.ConsumerManageProcessor.processRequest(ConsumerManageProcessor.java:65) ConsumerManageThread_23 org.apache.rocketmq.remoting.netty.NettyRemotingAbstract.lambda$buildProcessRequestHandler$1(NettyRemotingAbstract.java:331) ConsumerManageThread_23 org.apache.rocketmq.remoting.netty.NettyRemotingAbstract$$Lambda$140/1962033992.run(Unknown Source) ConsumerManageThread_23 org.apache.rocketmq.remoting.netty.RequestTask.run(RequestTask.java:80) ConsumerManageThread_23 java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ConsumerManageThread_23 java.util.concurrent.FutureTask.run(FutureTask.java:266) ConsumerManageThread_23 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ConsumerManageThread_23 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ConsumerManageThread_23 java.lang.Thread.run(Thread.java:750) ConsumerManageThread_11 TID: 146 STATE: WAITING ConsumerManageThread_11 sun.misc.Unsafe.park(Native Method) ConsumerManageThread_11 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ConsumerManageThread_11 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ConsumerManageThread_11 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ConsumerManageThread_11 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ConsumerManageThread_11 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ConsumerManageThread_11 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ConsumerManageThread_11 java.lang.Thread.run(Thread.java:750) ConsumerManageThread_27 TID: 162 STATE: WAITING ConsumerManageThread_27 sun.misc.Unsafe.defineClass(Native Method) ConsumerManageThread_27 sun.reflect.ClassDefiner.defineClass(ClassDefiner.java:63) ConsumerManageThread_27 sun.reflect.MethodAccessorGenerator$1.run(MethodAccessorGenerator.java:399) ConsumerManageThread_27 sun.reflect.MethodAccessorGenerator$1.run(MethodAccessorGenerator.java:394) ConsumerManageThread_27 java.security.AccessController.doPrivileged(Native Method) ConsumerManageThread_27 sun.reflect.MethodAccessorGenerator.generate(MethodAccessorGenerator.java:393) ConsumerManageThread_27 sun.reflect.MethodAccessorGenerator.generateConstructor(MethodAccessorGenerator.java:92) ConsumerManageThread_27 sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:55) ConsumerManageThread_27 sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) ConsumerManageThread_27 java.lang.reflect.Constructor.newInstance(Constructor.java:423) ConsumerManageThread_27 org.apache.rocketmq.remoting.protocol.RemotingCommand.decodeCommandCustomHeaderDirectly(RemotingCommand.java:280) ConsumerManageThread_27 org.apache.rocketmq.remoting.protocol.RemotingCommand.decodeCommandCustomHeader(RemotingCommand.java:272) ConsumerManageThread_27 org.apache.rocketmq.remoting.protocol.RemotingCommand.decodeCommandCustomHeader(RemotingCommand.java:264) ConsumerManageThread_27 org.apache.rocketmq.acl.plain.PlainAccessResource.parse(PlainAccessResource.java:172) ConsumerManageThread_27 org.apache.rocketmq.acl.plain.PlainAccessValidator.parse(PlainAccessValidator.java:40) ConsumerManageThread_27 org.apache.rocketmq.broker.BrokerController$18.doBeforeRequest(BrokerController.java:993) ConsumerManageThread_27 org.apache.rocketmq.remoting.netty.NettyRemotingAbstract.doBeforeRpcHooks(NettyRemotingAbstract.java:192) ConsumerManageThread_27 org.apache.rocketmq.remoting.netty.NettyRemotingAbstract.lambda$buildProcessRequestHandler$1(NettyRemotingAbstract.java:323) ConsumerManageThread_27 org.apache.rocketmq.remoting.netty.NettyRemotingAbstract$$Lambda$140/1962033992.run(Unknown Source) ConsumerManageThread_27 org.apache.rocketmq.remoting.netty.RequestTask.run(RequestTask.java:80) ConsumerManageThread_27 java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ConsumerManageThread_27 java.util.concurrent.FutureTask.run(FutureTask.java:266) ConsumerManageThread_27 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ConsumerManageThread_27 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ConsumerManageThread_27 java.lang.Thread.run(Thread.java:750) NettyServerScheduler_1 TID: 78 STATE: TIMED_WAITING NettyServerScheduler_1 sun.misc.Unsafe.park(Native Method) NettyServerScheduler_1 java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) NettyServerScheduler_1 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) NettyServerScheduler_1 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093) NettyServerScheduler_1 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) NettyServerScheduler_1 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) NettyServerScheduler_1 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) NettyServerScheduler_1 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) NettyServerScheduler_1 java.lang.Thread.run(Thread.java:750) ClientManageThread_18 TID: 259 STATE: WAITING ClientManageThread_18 sun.misc.Unsafe.park(Native Method) ClientManageThread_18 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ClientManageThread_18 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ClientManageThread_18 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ClientManageThread_18 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ClientManageThread_18 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ClientManageThread_18 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ClientManageThread_18 java.lang.Thread.run(Thread.java:750) ClientManageThread_10 TID: 231 STATE: WAITING ClientManageThread_10 sun.misc.Unsafe.park(Native Method) ClientManageThread_10 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ClientManageThread_10 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ClientManageThread_10 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ClientManageThread_10 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ClientManageThread_10 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ClientManageThread_10 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ClientManageThread_10 java.lang.Thread.run(Thread.java:750) ConsumerManageThread_12 TID: 147 STATE: WAITING ConsumerManageThread_12 sun.misc.Unsafe.park(Native Method) ConsumerManageThread_12 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ConsumerManageThread_12 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ConsumerManageThread_12 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ConsumerManageThread_12 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ConsumerManageThread_12 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ConsumerManageThread_12 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ConsumerManageThread_12 java.lang.Thread.run(Thread.java:750) brokerOutApi_thread_3 TID: 125 STATE: WAITING brokerOutApi_thread_3 sun.misc.Unsafe.park(Native Method) brokerOutApi_thread_3 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) brokerOutApi_thread_3 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) brokerOutApi_thread_3 java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403) brokerOutApi_thread_3 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) brokerOutApi_thread_3 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) brokerOutApi_thread_3 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) brokerOutApi_thread_3 java.lang.Thread.run(Thread.java:750) PopLongPollingService TID: 80 STATE: TIMED_WAITING PopLongPollingService sun.misc.Unsafe.park(Native Method) PopLongPollingService java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) PopLongPollingService java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037) PopLongPollingService java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328) PopLongPollingService org.apache.rocketmq.common.CountDownLatch2.await(CountDownLatch2.java:114) PopLongPollingService org.apache.rocketmq.common.ServiceThread.waitForRunning(ServiceThread.java:117) PopLongPollingService org.apache.rocketmq.broker.longpolling.PopLongPollingService.run(PopLongPollingService.java:77) PopLongPollingService java.lang.Thread.run(Thread.java:750) ConsumerManageThread_1 TID: 136 STATE: WAITING ConsumerManageThread_1 java.lang.Class.getDeclaredConstructors0(Native Method) ConsumerManageThread_1 java.lang.Class.privateGetDeclaredConstructors(Class.java:2671) ConsumerManageThread_1 java.lang.Class.getConstructor0(Class.java:3075) ConsumerManageThread_1 java.lang.Class.newInstance(Class.java:412) ConsumerManageThread_1 sun.reflect.MethodAccessorGenerator$1.run(MethodAccessorGenerator.java:403) ConsumerManageThread_1 sun.reflect.MethodAccessorGenerator$1.run(MethodAccessorGenerator.java:394) ConsumerManageThread_1 java.security.AccessController.doPrivileged(Native Method) ConsumerManageThread_1 sun.reflect.MethodAccessorGenerator.generate(MethodAccessorGenerator.java:393) ConsumerManageThread_1 sun.reflect.MethodAccessorGenerator.generateConstructor(MethodAccessorGenerator.java:92) ConsumerManageThread_1 sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:55) ConsumerManageThread_1 sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) ConsumerManageThread_1 java.lang.reflect.Constructor.newInstance(Constructor.java:423) ConsumerManageThread_1 org.apache.rocketmq.remoting.protocol.RemotingCommand.decodeCommandCustomHeaderDirectly(RemotingCommand.java:280) ConsumerManageThread_1 org.apache.rocketmq.remoting.protocol.RemotingCommand.decodeCommandCustomHeader(RemotingCommand.java:272) ConsumerManageThread_1 org.apache.rocketmq.remoting.protocol.RemotingCommand.decodeCommandCustomHeader(RemotingCommand.java:264) ConsumerManageThread_1 org.apache.rocketmq.acl.plain.PlainAccessResource.parse(PlainAccessResource.java:172) ConsumerManageThread_1 org.apache.rocketmq.acl.plain.PlainAccessValidator.parse(PlainAccessValidator.java:40) ConsumerManageThread_1 org.apache.rocketmq.broker.BrokerController$18.doBeforeRequest(BrokerController.java:993) ConsumerManageThread_1 org.apache.rocketmq.remoting.netty.NettyRemotingAbstract.doBeforeRpcHooks(NettyRemotingAbstract.java:192) ConsumerManageThread_1 org.apache.rocketmq.remoting.netty.NettyRemotingAbstract.lambda$buildProcessRequestHandler$1(NettyRemotingAbstract.java:323) ConsumerManageThread_1 org.apache.rocketmq.remoting.netty.NettyRemotingAbstract$$Lambda$140/1962033992.run(Unknown Source) ConsumerManageThread_1 org.apache.rocketmq.remoting.netty.RequestTask.run(RequestTask.java:80) ConsumerManageThread_1 java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ConsumerManageThread_1 java.util.concurrent.FutureTask.run(FutureTask.java:266) ConsumerManageThread_1 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ConsumerManageThread_1 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ConsumerManageThread_1 java.lang.Thread.run(Thread.java:750) NettyEventExecutor TID: 43 STATE: TIMED_WAITING NettyEventExecutor sun.misc.Unsafe.park(Native Method) NettyEventExecutor java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) NettyEventExecutor java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) NettyEventExecutor java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467) NettyEventExecutor org.apache.rocketmq.remoting.netty.NettyRemotingAbstract$NettyEventExecutor.run(NettyRemotingAbstract.java:689) NettyEventExecutor java.lang.Thread.run(Thread.java:750) ConsumerManageThread_17 TID: 152 STATE: WAITING ConsumerManageThread_17 sun.misc.Unsafe.park(Native Method) ConsumerManageThread_17 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ConsumerManageThread_17 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ConsumerManageThread_17 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ConsumerManageThread_17 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ConsumerManageThread_17 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ConsumerManageThread_17 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ConsumerManageThread_17 java.lang.Thread.run(Thread.java:750) PopReviveService_4 TID: 87 STATE: TIMED_WAITING PopReviveService_4 java.lang.Thread.sleep(Native Method) PopReviveService_4 org.apache.rocketmq.broker.processor.PopReviveService.consumeReviveMessage(PopReviveService.java:333) PopReviveService_4 org.apache.rocketmq.broker.processor.PopReviveService.run(PopReviveService.java:637) PopReviveService_4 java.lang.Thread.run(Thread.java:750) NettyServerCodecThread_1 TID: 207 STATE: WAITING NettyServerCodecThread_1 sun.misc.Unsafe.park(Native Method) NettyServerCodecThread_1 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) NettyServerCodecThread_1 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) NettyServerCodecThread_1 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) NettyServerCodecThread_1 io.netty.util.concurrent.SingleThreadEventExecutor.takeTask(SingleThreadEventExecutor.java:243) NettyServerCodecThread_1 io.netty.util.concurrent.DefaultEventExecutor.run(DefaultEventExecutor.java:64) NettyServerCodecThread_1 io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) NettyServerCodecThread_1 io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) NettyServerCodecThread_1 java.lang.Thread.run(Thread.java:750) ScheduleMessageTimerThread_4 TID: 106 STATE: WAITING ScheduleMessageTimerThread_4 sun.misc.Unsafe.park(Native Method) ScheduleMessageTimerThread_4 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ScheduleMessageTimerThread_4 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ScheduleMessageTimerThread_4 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088) ScheduleMessageTimerThread_4 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) ScheduleMessageTimerThread_4 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ScheduleMessageTimerThread_4 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ScheduleMessageTimerThread_4 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ScheduleMessageTimerThread_4 java.lang.Thread.run(Thread.java:750) AsyncAppender-Worker-RocketmqBrokerSiftingAppenderTID: 11 STATE: WAITING AsyncAppender-Worker-RocketmqBrokerSiftingAppendersun.misc.Unsafe.park(Native Method) AsyncAppender-Worker-RocketmqBrokerSiftingAppenderjava.util.concurrent.locks.LockSupport.park(LockSupport.java:175) AsyncAppender-Worker-RocketmqBrokerSiftingAppenderjava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) AsyncAppender-Worker-RocketmqBrokerSiftingAppenderjava.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403) AsyncAppender-Worker-RocketmqBrokerSiftingAppenderorg.apache.rocketmq.logging.ch.qos.logback.core.AsyncAppenderBase$Worker.run(AsyncAppenderBase.java:298) TopicQueueMappingCleanService TID: 92 STATE: TIMED_WAITING TopicQueueMappingCleanService sun.misc.Unsafe.park(Native Method) TopicQueueMappingCleanService java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) TopicQueueMappingCleanService java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037) TopicQueueMappingCleanService java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328) TopicQueueMappingCleanService org.apache.rocketmq.common.CountDownLatch2.await(CountDownLatch2.java:114) TopicQueueMappingCleanService org.apache.rocketmq.common.ServiceThread.waitForRunning(ServiceThread.java:117) TopicQueueMappingCleanService org.apache.rocketmq.broker.topic.TopicQueueMappingCleanService.run(TopicQueueMappingCleanService.java:83) TopicQueueMappingCleanService java.lang.Thread.run(Thread.java:750) NettyServerCodecThread_8 TID: 241 STATE: WAITING NettyServerCodecThread_8 sun.misc.Unsafe.park(Native Method) NettyServerCodecThread_8 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) NettyServerCodecThread_8 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) NettyServerCodecThread_8 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) NettyServerCodecThread_8 io.netty.util.concurrent.SingleThreadEventExecutor.takeTask(SingleThreadEventExecutor.java:243) NettyServerCodecThread_8 io.netty.util.concurrent.DefaultEventExecutor.run(DefaultEventExecutor.java:64) NettyServerCodecThread_8 io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) NettyServerCodecThread_8 io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) NettyServerCodecThread_8 java.lang.Thread.run(Thread.java:750) ConsumerManageThread_2 TID: 137 STATE: WAITING ConsumerManageThread_2 sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) ConsumerManageThread_2 java.lang.reflect.Constructor.newInstance(Constructor.java:423) ConsumerManageThread_2 org.apache.rocketmq.remoting.protocol.RemotingCommand.createResponseCommand(RemotingCommand.java:159) ConsumerManageThread_2 org.apache.rocketmq.remoting.protocol.RemotingCommand.createResponseCommand(RemotingCommand.java:134) ConsumerManageThread_2 org.apache.rocketmq.broker.processor.ConsumerManageProcessor.updateConsumerOffset(ConsumerManageProcessor.java:148) ConsumerManageThread_2 org.apache.rocketmq.broker.processor.ConsumerManageProcessor.processRequest(ConsumerManageProcessor.java:65) ConsumerManageThread_2 org.apache.rocketmq.remoting.netty.NettyRemotingAbstract.lambda$buildProcessRequestHandler$1(NettyRemotingAbstract.java:331) ConsumerManageThread_2 org.apache.rocketmq.remoting.netty.NettyRemotingAbstract$$Lambda$140/1962033992.run(Unknown Source) ConsumerManageThread_2 org.apache.rocketmq.remoting.netty.RequestTask.run(RequestTask.java:80) ConsumerManageThread_2 java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ConsumerManageThread_2 java.util.concurrent.FutureTask.run(FutureTask.java:266) ConsumerManageThread_2 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ConsumerManageThread_2 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ConsumerManageThread_2 java.lang.Thread.run(Thread.java:750) ScheduleMessageTimerThread_14 TID: 116 STATE: WAITING ScheduleMessageTimerThread_14 sun.misc.Unsafe.park(Native Method) ScheduleMessageTimerThread_14 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ScheduleMessageTimerThread_14 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ScheduleMessageTimerThread_14 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088) ScheduleMessageTimerThread_14 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) ScheduleMessageTimerThread_14 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ScheduleMessageTimerThread_14 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ScheduleMessageTimerThread_14 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ScheduleMessageTimerThread_14 java.lang.Thread.run(Thread.java:750) TimerDequeueWarmService TID: 62 STATE: TIMED_WAITING TimerDequeueWarmService sun.misc.Unsafe.park(Native Method) TimerDequeueWarmService java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) TimerDequeueWarmService java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037) TimerDequeueWarmService java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328) TimerDequeueWarmService org.apache.rocketmq.common.CountDownLatch2.await(CountDownLatch2.java:114) TimerDequeueWarmService org.apache.rocketmq.common.ServiceThread.waitForRunning(ServiceThread.java:117) TimerDequeueWarmService org.apache.rocketmq.store.timer.TimerMessageStore$TimerDequeueWarmService.run(TimerMessageStore.java:1627) TimerDequeueWarmService java.lang.Thread.run(Thread.java:750) ScheduleMessageTimerThread_7 TID: 109 STATE: WAITING ScheduleMessageTimerThread_7 sun.misc.Unsafe.park(Native Method) ScheduleMessageTimerThread_7 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ScheduleMessageTimerThread_7 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ScheduleMessageTimerThread_7 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088) ScheduleMessageTimerThread_7 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) ScheduleMessageTimerThread_7 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ScheduleMessageTimerThread_7 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ScheduleMessageTimerThread_7 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ScheduleMessageTimerThread_7 java.lang.Thread.run(Thread.java:750) ClientManageThread_27 TID: 268 STATE: WAITING ClientManageThread_27 sun.misc.Unsafe.park(Native Method) ClientManageThread_27 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ClientManageThread_27 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ClientManageThread_27 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ClientManageThread_27 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ClientManageThread_27 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ClientManageThread_27 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ClientManageThread_27 java.lang.Thread.run(Thread.java:750) ClientManageThread_12 TID: 233 STATE: WAITING ClientManageThread_12 sun.misc.Unsafe.park(Native Method) ClientManageThread_12 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ClientManageThread_12 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ClientManageThread_12 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ClientManageThread_12 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ClientManageThread_12 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ClientManageThread_12 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ClientManageThread_12 java.lang.Thread.run(Thread.java:750) NettyClientScan_thread_3 TID: 53 STATE: WAITING NettyClientScan_thread_3 sun.misc.Unsafe.park(Native Method) NettyClientScan_thread_3 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) NettyClientScan_thread_3 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) NettyClientScan_thread_3 java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403) NettyClientScan_thread_3 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) NettyClientScan_thread_3 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) NettyClientScan_thread_3 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) NettyClientScan_thread_3 java.lang.Thread.run(Thread.java:750) NettyServerCodecThread_6 TID: 238 STATE: WAITING NettyServerCodecThread_6 sun.misc.Unsafe.park(Native Method) NettyServerCodecThread_6 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) NettyServerCodecThread_6 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) NettyServerCodecThread_6 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) NettyServerCodecThread_6 io.netty.util.concurrent.SingleThreadEventExecutor.takeTask(SingleThreadEventExecutor.java:243) NettyServerCodecThread_6 io.netty.util.concurrent.DefaultEventExecutor.run(DefaultEventExecutor.java:64) NettyServerCodecThread_6 io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) NettyServerCodecThread_6 io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) NettyServerCodecThread_6 java.lang.Thread.run(Thread.java:750) TimerDequeueGetMessageService TID: 64 STATE: TIMED_WAITING TimerDequeueGetMessageService sun.misc.Unsafe.park(Native Method) TimerDequeueGetMessageService java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) TimerDequeueGetMessageService java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) TimerDequeueGetMessageService java.util.concurrent.LinkedBlockingDeque.pollFirst(LinkedBlockingDeque.java:522) TimerDequeueGetMessageService java.util.concurrent.LinkedBlockingDeque.poll(LinkedBlockingDeque.java:684) TimerDequeueGetMessageService org.apache.rocketmq.store.timer.TimerMessageStore$TimerDequeueGetMessageService.run(TimerMessageStore.java:1545) TimerDequeueGetMessageService java.lang.Thread.run(Thread.java:750) ConsumerManageThread_24 TID: 159 STATE: WAITING ConsumerManageThread_24 sun.misc.Unsafe.park(Native Method) ConsumerManageThread_24 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ConsumerManageThread_24 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ConsumerManageThread_24 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ConsumerManageThread_24 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ConsumerManageThread_24 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ConsumerManageThread_24 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ConsumerManageThread_24 java.lang.Thread.run(Thread.java:750) AdminBrokerThread_1 TID: 174 STATE: WAITING AdminBrokerThread_1 sun.misc.Unsafe.park(Native Method) AdminBrokerThread_1 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) AdminBrokerThread_1 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) AdminBrokerThread_1 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) AdminBrokerThread_1 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) AdminBrokerThread_1 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) AdminBrokerThread_1 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) AdminBrokerThread_1 java.lang.Thread.run(Thread.java:750) ConsumerManageThread_14 TID: 149 STATE: WAITING ConsumerManageThread_14 sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) ConsumerManageThread_14 java.lang.reflect.Constructor.newInstance(Constructor.java:423) ConsumerManageThread_14 org.apache.rocketmq.remoting.protocol.RemotingCommand.createResponseCommand(RemotingCommand.java:159) ConsumerManageThread_14 org.apache.rocketmq.remoting.protocol.RemotingCommand.createResponseCommand(RemotingCommand.java:134) ConsumerManageThread_14 org.apache.rocketmq.broker.processor.ConsumerManageProcessor.updateConsumerOffset(ConsumerManageProcessor.java:148) ConsumerManageThread_14 org.apache.rocketmq.broker.processor.ConsumerManageProcessor.processRequest(ConsumerManageProcessor.java:65) ConsumerManageThread_14 org.apache.rocketmq.remoting.netty.NettyRemotingAbstract.lambda$buildProcessRequestHandler$1(NettyRemotingAbstract.java:331) ConsumerManageThread_14 org.apache.rocketmq.remoting.netty.NettyRemotingAbstract$$Lambda$140/1962033992.run(Unknown Source) ConsumerManageThread_14 org.apache.rocketmq.remoting.netty.RequestTask.run(RequestTask.java:80) ConsumerManageThread_14 java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ConsumerManageThread_14 java.util.concurrent.FutureTask.run(FutureTask.java:266) ConsumerManageThread_14 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ConsumerManageThread_14 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ConsumerManageThread_14 java.lang.Thread.run(Thread.java:750) AsyncAppender-Worker-RocketmqRebalanceLockSiftingAppenderTID: 21 STATE: WAITING AsyncAppender-Worker-RocketmqRebalanceLockSiftingAppendersun.misc.Unsafe.park(Native Method) AsyncAppender-Worker-RocketmqRebalanceLockSiftingAppenderjava.util.concurrent.locks.LockSupport.park(LockSupport.java:175) AsyncAppender-Worker-RocketmqRebalanceLockSiftingAppenderjava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) AsyncAppender-Worker-RocketmqRebalanceLockSiftingAppenderjava.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403) AsyncAppender-Worker-RocketmqRebalanceLockSiftingAppenderorg.apache.rocketmq.logging.ch.qos.logback.core.AsyncAppenderBase$Worker.run(AsyncAppenderBase.java:298) NettyServerNIOSelector_1 TID: 129 STATE: RUNNABLE NettyServerNIOSelector_1 sun.nio.ch.EPollArrayWrapper.epollWait(Native Method) NettyServerNIOSelector_1 sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269) NettyServerNIOSelector_1 sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93) NettyServerNIOSelector_1 sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86) NettyServerNIOSelector_1 sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97) NettyServerNIOSelector_1 sun.nio.ch.SelectorImpl.select(SelectorImpl.java:101) NettyServerNIOSelector_1 io.netty.channel.nio.SelectedSelectionKeySetSelector.select(SelectedSelectionKeySetSelector.java:68) NettyServerNIOSelector_1 io.netty.channel.nio.NioEventLoop.select(NioEventLoop.java:810) NettyServerNIOSelector_1 io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:457) NettyServerNIOSelector_1 io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) NettyServerNIOSelector_1 io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) NettyServerNIOSelector_1 java.lang.Thread.run(Thread.java:750) QueueLockManager TID: 82 STATE: TIMED_WAITING QueueLockManager sun.misc.Unsafe.park(Native Method) QueueLockManager java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) QueueLockManager java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037) QueueLockManager java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328) QueueLockManager org.apache.rocketmq.common.CountDownLatch2.await(CountDownLatch2.java:114) QueueLockManager org.apache.rocketmq.common.ServiceThread.waitForRunning(ServiceThread.java:117) QueueLockManager org.apache.rocketmq.broker.processor.PopMessageProcessor$QueueLockManager.run(PopMessageProcessor.java:922) QueueLockManager java.lang.Thread.run(Thread.java:750) BrokerFastFailureScheduledThread1 TID: 96 STATE: RUNNABLE BrokerFastFailureScheduledThread1 java.lang.Thread.dumpThreads(Native Method) BrokerFastFailureScheduledThread1 java.lang.Thread.getAllStackTraces(Thread.java:1615) BrokerFastFailureScheduledThread1 org.apache.rocketmq.common.UtilAll.jstack(UtilAll.java:483) BrokerFastFailureScheduledThread1 org.apache.rocketmq.broker.latency.BrokerFastFailure.cleanExpiredRequestInQueue(BrokerFastFailure.java:140) BrokerFastFailureScheduledThread1 org.apache.rocketmq.broker.latency.BrokerFastFailure.cleanExpiredRequest(BrokerFastFailure.java:101) BrokerFastFailureScheduledThread1 org.apache.rocketmq.broker.latency.BrokerFastFailure.access$100(BrokerFastFailure.java:38) BrokerFastFailureScheduledThread1 org.apache.rocketmq.broker.latency.BrokerFastFailure$1.run0(BrokerFastFailure.java:70) BrokerFastFailureScheduledThread1 org.apache.rocketmq.common.AbstractBrokerRunnable.run(AbstractBrokerRunnable.java:43) BrokerFastFailureScheduledThread1 java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) BrokerFastFailureScheduledThread1 java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) BrokerFastFailureScheduledThread1 java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) BrokerFastFailureScheduledThread1 java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) BrokerFastFailureScheduledThread1 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) BrokerFastFailureScheduledThread1 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) BrokerFastFailureScheduledThread1 java.lang.Thread.run(Thread.java:750) TransactionFlushService TID: 39 STATE: TIMED_WAITING TransactionFlushService sun.misc.Unsafe.park(Native Method) TransactionFlushService java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) TransactionFlushService java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037) TransactionFlushService java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328) TransactionFlushService org.apache.rocketmq.common.CountDownLatch2.await(CountDownLatch2.java:114) TransactionFlushService org.apache.rocketmq.common.ServiceThread.waitForRunning(ServiceThread.java:117) TransactionFlushService org.apache.rocketmq.broker.transaction.TransactionMetricsFlushService.run(TransactionMetricsFlushService.java:47) TransactionFlushService java.lang.Thread.run(Thread.java:750) NettyServerCodecThread_3 TID: 219 STATE: TIMED_WAITING NettyServerCodecThread_3 sun.misc.Unsafe.park(Native Method) NettyServerCodecThread_3 java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) NettyServerCodecThread_3 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) NettyServerCodecThread_3 java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467) NettyServerCodecThread_3 io.netty.util.concurrent.SingleThreadEventExecutor.takeTask(SingleThreadEventExecutor.java:256) NettyServerCodecThread_3 io.netty.util.concurrent.DefaultEventExecutor.run(DefaultEventExecutor.java:64) NettyServerCodecThread_3 io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) NettyServerCodecThread_3 io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) NettyServerCodecThread_3 java.lang.Thread.run(Thread.java:750) NettyClientScan_thread_2 TID: 51 STATE: WAITING NettyClientScan_thread_2 sun.misc.Unsafe.park(Native Method) NettyClientScan_thread_2 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) NettyClientScan_thread_2 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) NettyClientScan_thread_2 java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403) NettyClientScan_thread_2 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) NettyClientScan_thread_2 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) NettyClientScan_thread_2 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) NettyClientScan_thread_2 java.lang.Thread.run(Thread.java:750) ScheduleMessageTimerThread_13 TID: 115 STATE: WAITING ScheduleMessageTimerThread_13 sun.misc.Unsafe.park(Native Method) ScheduleMessageTimerThread_13 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ScheduleMessageTimerThread_13 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ScheduleMessageTimerThread_13 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088) ScheduleMessageTimerThread_13 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) ScheduleMessageTimerThread_13 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ScheduleMessageTimerThread_13 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ScheduleMessageTimerThread_13 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ScheduleMessageTimerThread_13 java.lang.Thread.run(Thread.java:750) ConsumerManageThread_16 TID: 151 STATE: WAITING ConsumerManageThread_16 java.lang.Class.getDeclaredConstructors0(Native Method) ConsumerManageThread_16 java.lang.Class.privateGetDeclaredConstructors(Class.java:2671) ConsumerManageThread_16 java.lang.Class.getConstructor0(Class.java:3075) ConsumerManageThread_16 java.lang.Class.newInstance(Class.java:412) ConsumerManageThread_16 sun.reflect.MethodAccessorGenerator$1.run(MethodAccessorGenerator.java:403) ConsumerManageThread_16 sun.reflect.MethodAccessorGenerator$1.run(MethodAccessorGenerator.java:394) ConsumerManageThread_16 java.security.AccessController.doPrivileged(Native Method) ConsumerManageThread_16 sun.reflect.MethodAccessorGenerator.generate(MethodAccessorGenerator.java:393) ConsumerManageThread_16 sun.reflect.MethodAccessorGenerator.generateConstructor(MethodAccessorGenerator.java:92) ConsumerManageThread_16 sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:55) ConsumerManageThread_16 sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) ConsumerManageThread_16 java.lang.reflect.Constructor.newInstance(Constructor.java:423) ConsumerManageThread_16 org.apache.rocketmq.remoting.protocol.RemotingCommand.createResponseCommand(RemotingCommand.java:159) ConsumerManageThread_16 org.apache.rocketmq.remoting.protocol.RemotingCommand.createResponseCommand(RemotingCommand.java:134) ConsumerManageThread_16 org.apache.rocketmq.broker.processor.ConsumerManageProcessor.updateConsumerOffset(ConsumerManageProcessor.java:148) ConsumerManageThread_16 org.apache.rocketmq.broker.processor.ConsumerManageProcessor.processRequest(ConsumerManageProcessor.java:65) ConsumerManageThread_16 org.apache.rocketmq.remoting.netty.NettyRemotingAbstract.lambda$buildProcessRequestHandler$1(NettyRemotingAbstract.java:331) ConsumerManageThread_16 org.apache.rocketmq.remoting.netty.NettyRemotingAbstract$$Lambda$140/1962033992.run(Unknown Source) ConsumerManageThread_16 org.apache.rocketmq.remoting.netty.RequestTask.run(RequestTask.java:80) ConsumerManageThread_16 java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ConsumerManageThread_16 java.util.concurrent.FutureTask.run(FutureTask.java:266) ConsumerManageThread_16 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ConsumerManageThread_16 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ConsumerManageThread_16 java.lang.Thread.run(Thread.java:750) PullMessageThread_16 TID: 191 STATE: WAITING PullMessageThread_16 sun.misc.Unsafe.park(Native Method) PullMessageThread_16 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) PullMessageThread_16 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) PullMessageThread_16 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) PullMessageThread_16 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) PullMessageThread_16 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) PullMessageThread_16 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) PullMessageThread_16 java.lang.Thread.run(Thread.java:750) FlushConsumeQueueService TID: 46 STATE: TIMED_WAITING FlushConsumeQueueService sun.misc.Unsafe.park(Native Method) FlushConsumeQueueService java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) FlushConsumeQueueService java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037) FlushConsumeQueueService java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328) FlushConsumeQueueService org.apache.rocketmq.common.CountDownLatch2.await(CountDownLatch2.java:114) FlushConsumeQueueService org.apache.rocketmq.common.ServiceThread.waitForRunning(ServiceThread.java:117) FlushConsumeQueueService org.apache.rocketmq.store.DefaultMessageStore$FlushConsumeQueueService.run(DefaultMessageStore.java:2672) FlushConsumeQueueService java.lang.Thread.run(Thread.java:750) ClientManageThread_25 TID: 266 STATE: WAITING ClientManageThread_25 sun.misc.Unsafe.park(Native Method) ClientManageThread_25 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ClientManageThread_25 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ClientManageThread_25 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ClientManageThread_25 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ClientManageThread_25 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ClientManageThread_25 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ClientManageThread_25 java.lang.Thread.run(Thread.java:750) TimerDequeueGetService TID: 63 STATE: TIMED_WAITING TimerDequeueGetService sun.misc.Unsafe.park(Native Method) TimerDequeueGetService java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) TimerDequeueGetService java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037) TimerDequeueGetService java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328) TimerDequeueGetService org.apache.rocketmq.common.CountDownLatch2.await(CountDownLatch2.java:114) TimerDequeueGetService org.apache.rocketmq.common.ServiceThread.waitForRunning(ServiceThread.java:117) TimerDequeueGetService org.apache.rocketmq.store.timer.TimerMessageStore$TimerDequeueGetService.run(TimerMessageStore.java:1437) TimerDequeueGetService java.lang.Thread.run(Thread.java:750) ClientManageThread_19 TID: 260 STATE: WAITING ClientManageThread_19 sun.misc.Unsafe.park(Native Method) ClientManageThread_19 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ClientManageThread_19 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ClientManageThread_19 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ClientManageThread_19 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ClientManageThread_19 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ClientManageThread_19 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ClientManageThread_19 java.lang.Thread.run(Thread.java:750) ConsumerManageThread_29 TID: 164 STATE: WAITING ConsumerManageThread_29 sun.misc.Unsafe.park(Native Method) ConsumerManageThread_29 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ConsumerManageThread_29 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ConsumerManageThread_29 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ConsumerManageThread_29 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ConsumerManageThread_29 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ConsumerManageThread_29 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ConsumerManageThread_29 java.lang.Thread.run(Thread.java:750) ScheduleMessageTimerThread_2 TID: 104 STATE: WAITING ScheduleMessageTimerThread_2 sun.misc.Unsafe.park(Native Method) ScheduleMessageTimerThread_2 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ScheduleMessageTimerThread_2 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ScheduleMessageTimerThread_2 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088) ScheduleMessageTimerThread_2 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) ScheduleMessageTimerThread_2 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ScheduleMessageTimerThread_2 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ScheduleMessageTimerThread_2 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ScheduleMessageTimerThread_2 java.lang.Thread.run(Thread.java:750) AsyncAppender-Worker-RocketmqProtectionSiftingAppenderTID: 12 STATE: WAITING AsyncAppender-Worker-RocketmqProtectionSiftingAppendersun.misc.Unsafe.park(Native Method) AsyncAppender-Worker-RocketmqProtectionSiftingAppenderjava.util.concurrent.locks.LockSupport.park(LockSupport.java:175) AsyncAppender-Worker-RocketmqProtectionSiftingAppenderjava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) AsyncAppender-Worker-RocketmqProtectionSiftingAppenderjava.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403) AsyncAppender-Worker-RocketmqProtectionSiftingAppenderorg.apache.rocketmq.logging.ch.qos.logback.core.AsyncAppenderBase$Worker.run(AsyncAppenderBase.java:298) AdminBrokerThread_3 TID: 176 STATE: WAITING AdminBrokerThread_3 sun.misc.Unsafe.park(Native Method) AdminBrokerThread_3 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) AdminBrokerThread_3 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) AdminBrokerThread_3 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) AdminBrokerThread_3 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) AdminBrokerThread_3 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) AdminBrokerThread_3 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) AdminBrokerThread_3 java.lang.Thread.run(Thread.java:750) SendMessageThread_1 TID: 196 STATE: WAITING SendMessageThread_1 sun.misc.Unsafe.park(Native Method) SendMessageThread_1 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) SendMessageThread_1 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) SendMessageThread_1 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) SendMessageThread_1 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) SendMessageThread_1 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) SendMessageThread_1 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) SendMessageThread_1 java.lang.Thread.run(Thread.java:750) ClientManageThread_21 TID: 262 STATE: WAITING ClientManageThread_21 sun.misc.Unsafe.park(Native Method) ClientManageThread_21 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ClientManageThread_21 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ClientManageThread_21 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ClientManageThread_21 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ClientManageThread_21 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ClientManageThread_21 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ClientManageThread_21 java.lang.Thread.run(Thread.java:750) ConsumerManageThread_6 TID: 141 STATE: WAITING ConsumerManageThread_6 sun.misc.Unsafe.defineClass(Native Method) ConsumerManageThread_6 sun.reflect.ClassDefiner.defineClass(ClassDefiner.java:63) ConsumerManageThread_6 sun.reflect.MethodAccessorGenerator$1.run(MethodAccessorGenerator.java:399) ConsumerManageThread_6 sun.reflect.MethodAccessorGenerator$1.run(MethodAccessorGenerator.java:394) ConsumerManageThread_6 java.security.AccessController.doPrivileged(Native Method) ConsumerManageThread_6 sun.reflect.MethodAccessorGenerator.generate(MethodAccessorGenerator.java:393) ConsumerManageThread_6 sun.reflect.MethodAccessorGenerator.generateConstructor(MethodAccessorGenerator.java:92) ConsumerManageThread_6 sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:55) ConsumerManageThread_6 sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) ConsumerManageThread_6 java.lang.reflect.Constructor.newInstance(Constructor.java:423) ConsumerManageThread_6 org.apache.rocketmq.remoting.protocol.RemotingCommand.createResponseCommand(RemotingCommand.java:159) ConsumerManageThread_6 org.apache.rocketmq.remoting.protocol.RemotingCommand.createResponseCommand(RemotingCommand.java:134) ConsumerManageThread_6 org.apache.rocketmq.broker.processor.ConsumerManageProcessor.updateConsumerOffset(ConsumerManageProcessor.java:148) ConsumerManageThread_6 org.apache.rocketmq.broker.processor.ConsumerManageProcessor.processRequest(ConsumerManageProcessor.java:65) ConsumerManageThread_6 org.apache.rocketmq.remoting.netty.NettyRemotingAbstract.lambda$buildProcessRequestHandler$1(NettyRemotingAbstract.java:331) ConsumerManageThread_6 org.apache.rocketmq.remoting.netty.NettyRemotingAbstract$$Lambda$140/1962033992.run(Unknown Source) ConsumerManageThread_6 org.apache.rocketmq.remoting.netty.RequestTask.run(RequestTask.java:80) ConsumerManageThread_6 java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ConsumerManageThread_6 java.util.concurrent.FutureTask.run(FutureTask.java:266) ConsumerManageThread_6 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ConsumerManageThread_6 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ConsumerManageThread_6 java.lang.Thread.run(Thread.java:750) PullMessageThread_10 TID: 185 STATE: WAITING PullMessageThread_10 sun.misc.Unsafe.park(Native Method) PullMessageThread_10 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) PullMessageThread_10 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) PullMessageThread_10 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) PullMessageThread_10 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) PullMessageThread_10 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) PullMessageThread_10 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) PullMessageThread_10 java.lang.Thread.run(Thread.java:750) ConsumerManageThread_32 TID: 167 STATE: WAITING ConsumerManageThread_32 sun.misc.Unsafe.park(Native Method) ConsumerManageThread_32 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ConsumerManageThread_32 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ConsumerManageThread_32 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ConsumerManageThread_32 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ConsumerManageThread_32 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ConsumerManageThread_32 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ConsumerManageThread_32 java.lang.Thread.run(Thread.java:750) ScheduleMessageTimerThread_12 TID: 114 STATE: WAITING ScheduleMessageTimerThread_12 sun.misc.Unsafe.park(Native Method) ScheduleMessageTimerThread_12 java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) ScheduleMessageTimerThread_12 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) ScheduleMessageTimerThread_12 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093) ScheduleMessageTimerThread_12 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) ScheduleMessageTimerThread_12 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ScheduleMessageTimerThread_12 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ScheduleMessageTimerThread_12 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ScheduleMessageTimerThread_12 java.lang.Thread.run(Thread.java:750) QueryMessageThread_1 TID: 303 STATE: WAITING QueryMessageThread_1 sun.misc.Unsafe.park(Native Method) QueryMessageThread_1 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) QueryMessageThread_1 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) QueryMessageThread_1 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) QueryMessageThread_1 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) QueryMessageThread_1 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) QueryMessageThread_1 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) QueryMessageThread_1 java.lang.Thread.run(Thread.java:750) ConsumerManageThread_26 TID: 161 STATE: WAITING ConsumerManageThread_26 sun.misc.Unsafe.park(Native Method) ConsumerManageThread_26 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ConsumerManageThread_26 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ConsumerManageThread_26 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ConsumerManageThread_26 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ConsumerManageThread_26 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ConsumerManageThread_26 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ConsumerManageThread_26 java.lang.Thread.run(Thread.java:750) ClientManageThread_3 TID: 224 STATE: WAITING ClientManageThread_3 sun.misc.Unsafe.park(Native Method) ClientManageThread_3 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ClientManageThread_3 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ClientManageThread_3 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ClientManageThread_3 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ClientManageThread_3 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ClientManageThread_3 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ClientManageThread_3 java.lang.Thread.run(Thread.java:750) ScheduleMessageTimerThread_1 TID: 103 STATE: WAITING ScheduleMessageTimerThread_1 sun.misc.Unsafe.park(Native Method) ScheduleMessageTimerThread_1 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ScheduleMessageTimerThread_1 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ScheduleMessageTimerThread_1 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088) ScheduleMessageTimerThread_1 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) ScheduleMessageTimerThread_1 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ScheduleMessageTimerThread_1 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ScheduleMessageTimerThread_1 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ScheduleMessageTimerThread_1 java.lang.Thread.run(Thread.java:750) ThreadUtils-StatisticsManagerCleaner_1 TID: 27 STATE: TIMED_WAITING ThreadUtils-StatisticsManagerCleaner_1 sun.misc.Unsafe.park(Native Method) ThreadUtils-StatisticsManagerCleaner_1 java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) ThreadUtils-StatisticsManagerCleaner_1 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) ThreadUtils-StatisticsManagerCleaner_1 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093) ThreadUtils-StatisticsManagerCleaner_1 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) ThreadUtils-StatisticsManagerCleaner_1 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ThreadUtils-StatisticsManagerCleaner_1 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ThreadUtils-StatisticsManagerCleaner_1 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ThreadUtils-StatisticsManagerCleaner_1 java.lang.Thread.run(Thread.java:750) AsyncAppender-Worker-RocketmqWaterMarkSiftingAppenderTID: 13 STATE: WAITING AsyncAppender-Worker-RocketmqWaterMarkSiftingAppendersun.misc.Unsafe.park(Native Method) AsyncAppender-Worker-RocketmqWaterMarkSiftingAppenderjava.util.concurrent.locks.LockSupport.park(LockSupport.java:175) AsyncAppender-Worker-RocketmqWaterMarkSiftingAppenderjava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) AsyncAppender-Worker-RocketmqWaterMarkSiftingAppenderjava.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403) AsyncAppender-Worker-RocketmqWaterMarkSiftingAppenderorg.apache.rocketmq.logging.ch.qos.logback.core.AsyncAppenderBase$Worker.run(AsyncAppenderBase.java:298) PullMessageThread_12 TID: 187 STATE: WAITING PullMessageThread_12 sun.misc.Unsafe.park(Native Method) PullMessageThread_12 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) PullMessageThread_12 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) PullMessageThread_12 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) PullMessageThread_12 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) PullMessageThread_12 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) PullMessageThread_12 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) PullMessageThread_12 java.lang.Thread.run(Thread.java:750) PullMessageThread_6 TID: 173 STATE: WAITING PullMessageThread_6 sun.misc.Unsafe.park(Native Method) PullMessageThread_6 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) PullMessageThread_6 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) PullMessageThread_6 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) PullMessageThread_6 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) PullMessageThread_6 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) PullMessageThread_6 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) PullMessageThread_6 java.lang.Thread.run(Thread.java:750) NettyEventExecutor TID: 77 STATE: TIMED_WAITING NettyEventExecutor sun.misc.Unsafe.park(Native Method) NettyEventExecutor java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) NettyEventExecutor java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) NettyEventExecutor java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467) NettyEventExecutor org.apache.rocketmq.remoting.netty.NettyRemotingAbstract$NettyEventExecutor.run(NettyRemotingAbstract.java:689) NettyEventExecutor java.lang.Thread.run(Thread.java:750) QueryMessageThread_5 TID: 307 STATE: WAITING QueryMessageThread_5 sun.misc.Unsafe.park(Native Method) QueryMessageThread_5 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) QueryMessageThread_5 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) QueryMessageThread_5 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) QueryMessageThread_5 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) QueryMessageThread_5 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) QueryMessageThread_5 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) QueryMessageThread_5 java.lang.Thread.run(Thread.java:750) ConsumerManageThread_22 TID: 157 STATE: WAITING ConsumerManageThread_22 sun.misc.Unsafe.park(Native Method) ConsumerManageThread_22 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ConsumerManageThread_22 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ConsumerManageThread_22 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ConsumerManageThread_22 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ConsumerManageThread_22 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ConsumerManageThread_22 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ConsumerManageThread_22 java.lang.Thread.run(Thread.java:750) NettyServerCodecThread_3 TID: 135 STATE: TIMED_WAITING NettyServerCodecThread_3 sun.misc.Unsafe.park(Native Method) NettyServerCodecThread_3 java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) NettyServerCodecThread_3 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) NettyServerCodecThread_3 java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467) NettyServerCodecThread_3 io.netty.util.concurrent.SingleThreadEventExecutor.takeTask(SingleThreadEventExecutor.java:256) NettyServerCodecThread_3 io.netty.util.concurrent.DefaultEventExecutor.run(DefaultEventExecutor.java:64) NettyServerCodecThread_3 io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) NettyServerCodecThread_3 io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) NettyServerCodecThread_3 java.lang.Thread.run(Thread.java:750) ConsumerManageThread_21 TID: 156 STATE: WAITING ConsumerManageThread_21 sun.misc.Unsafe.park(Native Method) ConsumerManageThread_21 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ConsumerManageThread_21 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ConsumerManageThread_21 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ConsumerManageThread_21 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ConsumerManageThread_21 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ConsumerManageThread_21 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ConsumerManageThread_21 java.lang.Thread.run(Thread.java:750) NettyServerNIOSelector_2 TID: 213 STATE: RUNNABLE NettyServerNIOSelector_2 sun.nio.ch.EPollArrayWrapper.epollWait(Native Method) NettyServerNIOSelector_2 sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269) NettyServerNIOSelector_2 sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93) NettyServerNIOSelector_2 sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86) NettyServerNIOSelector_2 sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97) NettyServerNIOSelector_2 sun.nio.ch.SelectorImpl.select(SelectorImpl.java:101) NettyServerNIOSelector_2 io.netty.channel.nio.SelectedSelectionKeySetSelector.select(SelectedSelectionKeySetSelector.java:68) NettyServerNIOSelector_2 io.netty.channel.nio.NioEventLoop.select(NioEventLoop.java:810) NettyServerNIOSelector_2 io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:457) NettyServerNIOSelector_2 io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) NettyServerNIOSelector_2 io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) NettyServerNIOSelector_2 java.lang.Thread.run(Thread.java:750) ClientManageThread_6 TID: 227 STATE: WAITING ClientManageThread_6 sun.misc.Unsafe.park(Native Method) ClientManageThread_6 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ClientManageThread_6 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ClientManageThread_6 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ClientManageThread_6 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ClientManageThread_6 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ClientManageThread_6 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ClientManageThread_6 java.lang.Thread.run(Thread.java:750) ClientManageThread_5 TID: 226 STATE: WAITING ClientManageThread_5 sun.misc.Unsafe.park(Native Method) ClientManageThread_5 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ClientManageThread_5 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ClientManageThread_5 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ClientManageThread_5 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ClientManageThread_5 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ClientManageThread_5 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ClientManageThread_5 java.lang.Thread.run(Thread.java:750) TimerDequeueGetMessageService TID: 66 STATE: TIMED_WAITING TimerDequeueGetMessageService sun.misc.Unsafe.park(Native Method) TimerDequeueGetMessageService java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) TimerDequeueGetMessageService java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) TimerDequeueGetMessageService java.util.concurrent.LinkedBlockingDeque.pollFirst(LinkedBlockingDeque.java:522) TimerDequeueGetMessageService java.util.concurrent.LinkedBlockingDeque.poll(LinkedBlockingDeque.java:684) TimerDequeueGetMessageService org.apache.rocketmq.store.timer.TimerMessageStore$TimerDequeueGetMessageService.run(TimerMessageStore.java:1545) TimerDequeueGetMessageService java.lang.Thread.run(Thread.java:750) TimerDequeuePutMessageService TID: 68 STATE: TIMED_WAITING TimerDequeuePutMessageService sun.misc.Unsafe.park(Native Method) TimerDequeuePutMessageService java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) TimerDequeuePutMessageService java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) TimerDequeuePutMessageService java.util.concurrent.LinkedBlockingDeque.pollFirst(LinkedBlockingDeque.java:522) TimerDequeuePutMessageService java.util.concurrent.LinkedBlockingDeque.poll(LinkedBlockingDeque.java:684) TimerDequeuePutMessageService org.apache.rocketmq.store.timer.TimerMessageStore$TimerDequeuePutMessageService.run(TimerMessageStore.java:1474) TimerDequeuePutMessageService java.lang.Thread.run(Thread.java:750) NettyClientScan_thread_4 TID: 127 STATE: WAITING NettyClientScan_thread_4 sun.misc.Unsafe.park(Native Method) NettyClientScan_thread_4 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) NettyClientScan_thread_4 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) NettyClientScan_thread_4 java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403) NettyClientScan_thread_4 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) NettyClientScan_thread_4 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) NettyClientScan_thread_4 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) NettyClientScan_thread_4 java.lang.Thread.run(Thread.java:750) PullMessageThread_8 TID: 179 STATE: WAITING PullMessageThread_8 sun.misc.Unsafe.park(Native Method) PullMessageThread_8 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) PullMessageThread_8 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) PullMessageThread_8 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) PullMessageThread_8 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) PullMessageThread_8 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) PullMessageThread_8 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) PullMessageThread_8 java.lang.Thread.run(Thread.java:750) NettyClientSelector_1 TID: 73 STATE: RUNNABLE NettyClientSelector_1 sun.nio.ch.EPollArrayWrapper.epollWait(Native Method) NettyClientSelector_1 sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269) NettyClientSelector_1 sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93) NettyClientSelector_1 sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86) NettyClientSelector_1 sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97) NettyClientSelector_1 sun.nio.ch.SelectorImpl.select(SelectorImpl.java:101) NettyClientSelector_1 io.netty.channel.nio.SelectedSelectionKeySetSelector.select(SelectedSelectionKeySetSelector.java:68) NettyClientSelector_1 io.netty.channel.nio.NioEventLoop.select(NioEventLoop.java:810) NettyClientSelector_1 io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:457) NettyClientSelector_1 io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) NettyClientSelector_1 io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) NettyClientSelector_1 java.lang.Thread.run(Thread.java:750) DefaultAcceptSocketService TID: 54 STATE: RUNNABLE DefaultAcceptSocketService sun.nio.ch.EPollArrayWrapper.epollWait(Native Method) DefaultAcceptSocketService sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269) DefaultAcceptSocketService sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93) DefaultAcceptSocketService sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86) DefaultAcceptSocketService sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97) DefaultAcceptSocketService org.apache.rocketmq.store.ha.DefaultHAService$AcceptSocketService.run(DefaultHAService.java:340) DefaultAcceptSocketService java.lang.Thread.run(Thread.java:750) NettyServerCodecThread_8 TID: 203 STATE: WAITING NettyServerCodecThread_8 sun.misc.Unsafe.park(Native Method) NettyServerCodecThread_8 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) NettyServerCodecThread_8 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) NettyServerCodecThread_8 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) NettyServerCodecThread_8 io.netty.util.concurrent.SingleThreadEventExecutor.takeTask(SingleThreadEventExecutor.java:243) NettyServerCodecThread_8 io.netty.util.concurrent.DefaultEventExecutor.run(DefaultEventExecutor.java:64) NettyServerCodecThread_8 io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) NettyServerCodecThread_8 io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) NettyServerCodecThread_8 java.lang.Thread.run(Thread.java:750) AdminBrokerThread_5 TID: 181 STATE: WAITING AdminBrokerThread_5 sun.misc.Unsafe.park(Native Method) AdminBrokerThread_5 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) AdminBrokerThread_5 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) AdminBrokerThread_5 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) AdminBrokerThread_5 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) AdminBrokerThread_5 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) AdminBrokerThread_5 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) AdminBrokerThread_5 java.lang.Thread.run(Thread.java:750) TimerEnqueueGetService TID: 60 STATE: TIMED_WAITING TimerEnqueueGetService sun.misc.Unsafe.park(Native Method) TimerEnqueueGetService java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) TimerEnqueueGetService java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037) TimerEnqueueGetService java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328) TimerEnqueueGetService org.apache.rocketmq.common.CountDownLatch2.await(CountDownLatch2.java:114) TimerEnqueueGetService org.apache.rocketmq.common.ServiceThread.waitForRunning(ServiceThread.java:117) TimerEnqueueGetService org.apache.rocketmq.store.timer.TimerMessageStore$TimerEnqueueGetService.run(TimerMessageStore.java:1304) TimerEnqueueGetService java.lang.Thread.run(Thread.java:750) ConsumerManageThread_15 TID: 150 STATE: WAITING ConsumerManageThread_15 sun.misc.Unsafe.park(Native Method) ConsumerManageThread_15 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ConsumerManageThread_15 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ConsumerManageThread_15 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ConsumerManageThread_15 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ConsumerManageThread_15 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ConsumerManageThread_15 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ConsumerManageThread_15 java.lang.Thread.run(Thread.java:750) NettyServerCodecThread_4 TID: 194 STATE: TIMED_WAITING NettyServerCodecThread_4 sun.misc.Unsafe.park(Native Method) NettyServerCodecThread_4 java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) NettyServerCodecThread_4 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) NettyServerCodecThread_4 java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467) NettyServerCodecThread_4 io.netty.util.concurrent.SingleThreadEventExecutor.takeTask(SingleThreadEventExecutor.java:256) NettyServerCodecThread_4 io.netty.util.concurrent.DefaultEventExecutor.run(DefaultEventExecutor.java:64) NettyServerCodecThread_4 io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) NettyServerCodecThread_4 io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) NettyServerCodecThread_4 java.lang.Thread.run(Thread.java:750) ClientManageThread_11 TID: 232 STATE: WAITING ClientManageThread_11 sun.misc.Unsafe.park(Native Method) ClientManageThread_11 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ClientManageThread_11 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ClientManageThread_11 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ClientManageThread_11 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ClientManageThread_11 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ClientManageThread_11 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ClientManageThread_11 java.lang.Thread.run(Thread.java:750) ConsumerManageThread_28 TID: 163 STATE: WAITING ConsumerManageThread_28 sun.misc.Unsafe.park(Native Method) ConsumerManageThread_28 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ConsumerManageThread_28 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ConsumerManageThread_28 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ConsumerManageThread_28 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ConsumerManageThread_28 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ConsumerManageThread_28 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ConsumerManageThread_28 java.lang.Thread.run(Thread.java:750) NettyServerCodecThread_2 TID: 132 STATE: TIMED_WAITING NettyServerCodecThread_2 sun.misc.Unsafe.park(Native Method) NettyServerCodecThread_2 java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) NettyServerCodecThread_2 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) NettyServerCodecThread_2 java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467) NettyServerCodecThread_2 io.netty.util.concurrent.SingleThreadEventExecutor.takeTask(SingleThreadEventExecutor.java:256) NettyServerCodecThread_2 io.netty.util.concurrent.DefaultEventExecutor.run(DefaultEventExecutor.java:64) NettyServerCodecThread_2 io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) NettyServerCodecThread_2 io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) NettyServerCodecThread_2 java.lang.Thread.run(Thread.java:750) ScheduleMessageTimerThread_5 TID: 107 STATE: WAITING ScheduleMessageTimerThread_5 sun.misc.Unsafe.park(Native Method) ScheduleMessageTimerThread_5 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ScheduleMessageTimerThread_5 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ScheduleMessageTimerThread_5 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088) ScheduleMessageTimerThread_5 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) ScheduleMessageTimerThread_5 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ScheduleMessageTimerThread_5 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ScheduleMessageTimerThread_5 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ScheduleMessageTimerThread_5 java.lang.Thread.run(Thread.java:750) ClientManageThread_15 TID: 256 STATE: WAITING ClientManageThread_15 sun.misc.Unsafe.park(Native Method) ClientManageThread_15 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ClientManageThread_15 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ClientManageThread_15 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ClientManageThread_15 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ClientManageThread_15 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ClientManageThread_15 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ClientManageThread_15 java.lang.Thread.run(Thread.java:750) ScheduleMessageTimerThread_6 TID: 108 STATE: WAITING ScheduleMessageTimerThread_6 sun.misc.Unsafe.park(Native Method) ScheduleMessageTimerThread_6 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ScheduleMessageTimerThread_6 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ScheduleMessageTimerThread_6 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088) ScheduleMessageTimerThread_6 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) ScheduleMessageTimerThread_6 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ScheduleMessageTimerThread_6 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ScheduleMessageTimerThread_6 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ScheduleMessageTimerThread_6 java.lang.Thread.run(Thread.java:750) AsyncAppender-Worker-DefaultSiftingAppenderTID: 10 STATE: WAITING AsyncAppender-Worker-DefaultSiftingAppendersun.misc.Unsafe.park(Native Method) AsyncAppender-Worker-DefaultSiftingAppenderjava.util.concurrent.locks.LockSupport.park(LockSupport.java:175) AsyncAppender-Worker-DefaultSiftingAppenderjava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) AsyncAppender-Worker-DefaultSiftingAppenderjava.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403) AsyncAppender-Worker-DefaultSiftingAppenderorg.apache.rocketmq.logging.ch.qos.logback.core.AsyncAppenderBase$Worker.run(AsyncAppenderBase.java:298) PullMessageThread_14 TID: 189 STATE: WAITING PullMessageThread_14 sun.misc.Unsafe.park(Native Method) PullMessageThread_14 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) PullMessageThread_14 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) PullMessageThread_14 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) PullMessageThread_14 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) PullMessageThread_14 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) PullMessageThread_14 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) PullMessageThread_14 java.lang.Thread.run(Thread.java:750) NettyNIOBoss_1 TID: 72 STATE: RUNNABLE NettyNIOBoss_1 sun.nio.ch.EPollArrayWrapper.epollWait(Native Method) NettyNIOBoss_1 sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269) NettyNIOBoss_1 sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93) NettyNIOBoss_1 sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86) NettyNIOBoss_1 sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97) NettyNIOBoss_1 sun.nio.ch.SelectorImpl.select(SelectorImpl.java:101) NettyNIOBoss_1 io.netty.channel.nio.SelectedSelectionKeySetSelector.select(SelectedSelectionKeySetSelector.java:68) NettyNIOBoss_1 io.netty.channel.nio.NioEventLoop.select(NioEventLoop.java:810) NettyNIOBoss_1 io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:457) NettyNIOBoss_1 io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) NettyNIOBoss_1 io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) NettyNIOBoss_1 java.lang.Thread.run(Thread.java:750) ClientManageThread_17 TID: 258 STATE: WAITING ClientManageThread_17 sun.misc.Unsafe.park(Native Method) ClientManageThread_17 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ClientManageThread_17 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ClientManageThread_17 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ClientManageThread_17 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ClientManageThread_17 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ClientManageThread_17 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ClientManageThread_17 java.lang.Thread.run(Thread.java:750) AdminBrokerThread_7 TID: 183 STATE: WAITING AdminBrokerThread_7 sun.misc.Unsafe.park(Native Method) AdminBrokerThread_7 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) AdminBrokerThread_7 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) AdminBrokerThread_7 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) AdminBrokerThread_7 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) AdminBrokerThread_7 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) AdminBrokerThread_7 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) AdminBrokerThread_7 java.lang.Thread.run(Thread.java:750) TimerDequeueGetMessageService TID: 65 STATE: TIMED_WAITING TimerDequeueGetMessageService sun.misc.Unsafe.park(Native Method) TimerDequeueGetMessageService java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) TimerDequeueGetMessageService java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) TimerDequeueGetMessageService java.util.concurrent.LinkedBlockingDeque.pollFirst(LinkedBlockingDeque.java:522) TimerDequeueGetMessageService java.util.concurrent.LinkedBlockingDeque.poll(LinkedBlockingDeque.java:684) TimerDequeueGetMessageService org.apache.rocketmq.store.timer.TimerMessageStore$TimerDequeueGetMessageService.run(TimerMessageStore.java:1545) TimerDequeueGetMessageService java.lang.Thread.run(Thread.java:750) ScheduleMessageTimerThread_8 TID: 110 STATE: WAITING ScheduleMessageTimerThread_8 sun.misc.Unsafe.park(Native Method) ScheduleMessageTimerThread_8 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ScheduleMessageTimerThread_8 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ScheduleMessageTimerThread_8 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088) ScheduleMessageTimerThread_8 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) ScheduleMessageTimerThread_8 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ScheduleMessageTimerThread_8 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ScheduleMessageTimerThread_8 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ScheduleMessageTimerThread_8 java.lang.Thread.run(Thread.java:750) StoreCleanQueueScheduledThread1 TID: 58 STATE: TIMED_WAITING StoreCleanQueueScheduledThread1 sun.misc.Unsafe.park(Native Method) StoreCleanQueueScheduledThread1 java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) StoreCleanQueueScheduledThread1 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) StoreCleanQueueScheduledThread1 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093) StoreCleanQueueScheduledThread1 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) StoreCleanQueueScheduledThread1 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) StoreCleanQueueScheduledThread1 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) StoreCleanQueueScheduledThread1 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) StoreCleanQueueScheduledThread1 java.lang.Thread.run(Thread.java:750) AdminBrokerThread_15 TID: 211 STATE: WAITING AdminBrokerThread_15 sun.misc.Unsafe.park(Native Method) AdminBrokerThread_15 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) AdminBrokerThread_15 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) AdminBrokerThread_15 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) AdminBrokerThread_15 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) AdminBrokerThread_15 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) AdminBrokerThread_15 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) AdminBrokerThread_15 java.lang.Thread.run(Thread.java:750) ConsumerManageThread_3 TID: 138 STATE: WAITING ConsumerManageThread_3 sun.misc.Unsafe.park(Native Method) ConsumerManageThread_3 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ConsumerManageThread_3 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ConsumerManageThread_3 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ConsumerManageThread_3 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ConsumerManageThread_3 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ConsumerManageThread_3 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ConsumerManageThread_3 java.lang.Thread.run(Thread.java:750) DefaultConsumerIdsChangeListener_1 TID: 30 STATE: TIMED_WAITING DefaultConsumerIdsChangeListener_1 sun.misc.Unsafe.park(Native Method) DefaultConsumerIdsChangeListener_1 java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) DefaultConsumerIdsChangeListener_1 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) DefaultConsumerIdsChangeListener_1 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093) DefaultConsumerIdsChangeListener_1 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) DefaultConsumerIdsChangeListener_1 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) DefaultConsumerIdsChangeListener_1 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) DefaultConsumerIdsChangeListener_1 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) DefaultConsumerIdsChangeListener_1 java.lang.Thread.run(Thread.java:750) NettyClientScan_thread_1 TID: 49 STATE: WAITING NettyClientScan_thread_1 sun.misc.Unsafe.park(Native Method) NettyClientScan_thread_1 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) NettyClientScan_thread_1 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) NettyClientScan_thread_1 java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403) NettyClientScan_thread_1 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) NettyClientScan_thread_1 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) NettyClientScan_thread_1 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) NettyClientScan_thread_1 java.lang.Thread.run(Thread.java:750) QueryMessageThread_4 TID: 306 STATE: WAITING QueryMessageThread_4 sun.misc.Unsafe.park(Native Method) QueryMessageThread_4 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) QueryMessageThread_4 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) QueryMessageThread_4 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) QueryMessageThread_4 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) QueryMessageThread_4 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) QueryMessageThread_4 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) QueryMessageThread_4 java.lang.Thread.run(Thread.java:750) ConsumerManageThread_9 TID: 144 STATE: WAITING ConsumerManageThread_9 sun.misc.Unsafe.defineClass(Native Method) ConsumerManageThread_9 sun.reflect.ClassDefiner.defineClass(ClassDefiner.java:63) ConsumerManageThread_9 sun.reflect.MethodAccessorGenerator$1.run(MethodAccessorGenerator.java:399) ConsumerManageThread_9 sun.reflect.MethodAccessorGenerator$1.run(MethodAccessorGenerator.java:394) ConsumerManageThread_9 java.security.AccessController.doPrivileged(Native Method) ConsumerManageThread_9 sun.reflect.MethodAccessorGenerator.generate(MethodAccessorGenerator.java:393) ConsumerManageThread_9 sun.reflect.MethodAccessorGenerator.generateConstructor(MethodAccessorGenerator.java:92) ConsumerManageThread_9 sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:55) ConsumerManageThread_9 sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) ConsumerManageThread_9 java.lang.reflect.Constructor.newInstance(Constructor.java:423) ConsumerManageThread_9 org.apache.rocketmq.remoting.protocol.RemotingCommand.createResponseCommand(RemotingCommand.java:159) ConsumerManageThread_9 org.apache.rocketmq.remoting.protocol.RemotingCommand.createResponseCommand(RemotingCommand.java:134) ConsumerManageThread_9 org.apache.rocketmq.broker.processor.ConsumerManageProcessor.updateConsumerOffset(ConsumerManageProcessor.java:148) ConsumerManageThread_9 org.apache.rocketmq.broker.processor.ConsumerManageProcessor.processRequest(ConsumerManageProcessor.java:65) ConsumerManageThread_9 org.apache.rocketmq.remoting.netty.NettyRemotingAbstract.lambda$buildProcessRequestHandler$1(NettyRemotingAbstract.java:331) ConsumerManageThread_9 org.apache.rocketmq.remoting.netty.NettyRemotingAbstract$$Lambda$140/1962033992.run(Unknown Source) ConsumerManageThread_9 org.apache.rocketmq.remoting.netty.RequestTask.run(RequestTask.java:80) ConsumerManageThread_9 java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ConsumerManageThread_9 java.util.concurrent.FutureTask.run(FutureTask.java:266) ConsumerManageThread_9 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ConsumerManageThread_9 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ConsumerManageThread_9 java.lang.Thread.run(Thread.java:750) NettyServerCodecThread_7 TID: 239 STATE: WAITING NettyServerCodecThread_7 sun.misc.Unsafe.park(Native Method) NettyServerCodecThread_7 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) NettyServerCodecThread_7 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) NettyServerCodecThread_7 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) NettyServerCodecThread_7 io.netty.util.concurrent.SingleThreadEventExecutor.takeTask(SingleThreadEventExecutor.java:243) NettyServerCodecThread_7 io.netty.util.concurrent.DefaultEventExecutor.run(DefaultEventExecutor.java:64) NettyServerCodecThread_7 io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) NettyServerCodecThread_7 io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) NettyServerCodecThread_7 java.lang.Thread.run(Thread.java:750) BroadcastOffsetManager TID: 97 STATE: TIMED_WAITING BroadcastOffsetManager sun.misc.Unsafe.park(Native Method) BroadcastOffsetManager java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) BroadcastOffsetManager java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037) BroadcastOffsetManager java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328) BroadcastOffsetManager org.apache.rocketmq.common.CountDownLatch2.await(CountDownLatch2.java:114) BroadcastOffsetManager org.apache.rocketmq.common.ServiceThread.waitForRunning(ServiceThread.java:117) BroadcastOffsetManager org.apache.rocketmq.broker.offset.BroadcastOffsetManager.run(BroadcastOffsetManager.java:198) BroadcastOffsetManager java.lang.Thread.run(Thread.java:750) Finalizer TID: 3 STATE: WAITING Finalizer java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:139) Finalizer java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:165) Finalizer java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:188) PullMessageThread_1 TID: 168 STATE: WAITING PullMessageThread_1 sun.misc.Unsafe.park(Native Method) PullMessageThread_1 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) PullMessageThread_1 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) PullMessageThread_1 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) PullMessageThread_1 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) PullMessageThread_1 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) PullMessageThread_1 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) PullMessageThread_1 java.lang.Thread.run(Thread.java:750) AsyncAppender-Worker-RocketmqRebalanceLockSiftingAppenderTID: 22 STATE: WAITING AsyncAppender-Worker-RocketmqRebalanceLockSiftingAppendersun.misc.Unsafe.park(Native Method) AsyncAppender-Worker-RocketmqRebalanceLockSiftingAppenderjava.util.concurrent.locks.LockSupport.park(LockSupport.java:175) AsyncAppender-Worker-RocketmqRebalanceLockSiftingAppenderjava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) AsyncAppender-Worker-RocketmqRebalanceLockSiftingAppenderjava.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403) AsyncAppender-Worker-RocketmqRebalanceLockSiftingAppenderorg.apache.rocketmq.logging.ch.qos.logback.core.AsyncAppenderBase$Worker.run(AsyncAppenderBase.java:298) NettyServerNIOSelector_1 TID: 206 STATE: RUNNABLE NettyServerNIOSelector_1 sun.nio.ch.EPollArrayWrapper.epollWait(Native Method) NettyServerNIOSelector_1 sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269) NettyServerNIOSelector_1 sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93) NettyServerNIOSelector_1 sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86) NettyServerNIOSelector_1 sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97) NettyServerNIOSelector_1 sun.nio.ch.SelectorImpl.select(SelectorImpl.java:101) NettyServerNIOSelector_1 io.netty.channel.nio.SelectedSelectionKeySetSelector.select(SelectedSelectionKeySetSelector.java:68) NettyServerNIOSelector_1 io.netty.channel.nio.NioEventLoop.select(NioEventLoop.java:810) NettyServerNIOSelector_1 io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:457) NettyServerNIOSelector_1 io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) NettyServerNIOSelector_1 io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) NettyServerNIOSelector_1 java.lang.Thread.run(Thread.java:750) ClientManageThread_22 TID: 263 STATE: WAITING ClientManageThread_22 sun.misc.Unsafe.park(Native Method) ClientManageThread_22 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ClientManageThread_22 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ClientManageThread_22 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ClientManageThread_22 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ClientManageThread_22 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ClientManageThread_22 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ClientManageThread_22 java.lang.Thread.run(Thread.java:750) brokerOutApi_thread_4 TID: 193 STATE: WAITING brokerOutApi_thread_4 sun.misc.Unsafe.park(Native Method) brokerOutApi_thread_4 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) brokerOutApi_thread_4 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) brokerOutApi_thread_4 java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403) brokerOutApi_thread_4 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) brokerOutApi_thread_4 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) brokerOutApi_thread_4 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) brokerOutApi_thread_4 java.lang.Thread.run(Thread.java:750) AdminBrokerThread_10 TID: 204 STATE: WAITING AdminBrokerThread_10 sun.misc.Unsafe.park(Native Method) AdminBrokerThread_10 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) AdminBrokerThread_10 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) AdminBrokerThread_10 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) AdminBrokerThread_10 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) AdminBrokerThread_10 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) AdminBrokerThread_10 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) AdminBrokerThread_10 java.lang.Thread.run(Thread.java:750) AclFileWatchService TID: 41 STATE: TIMED_WAITING AclFileWatchService sun.misc.Unsafe.park(Native Method) AclFileWatchService java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) AclFileWatchService java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037) AclFileWatchService java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328) AclFileWatchService org.apache.rocketmq.common.CountDownLatch2.await(CountDownLatch2.java:114) AclFileWatchService org.apache.rocketmq.common.ServiceThread.waitForRunning(ServiceThread.java:117) AclFileWatchService org.apache.rocketmq.srvutil.AclFileWatchService.run(AclFileWatchService.java:100) AclFileWatchService java.lang.Thread.run(Thread.java:750) ClientManageThread_1 TID: 222 STATE: WAITING ClientManageThread_1 sun.misc.Unsafe.park(Native Method) ClientManageThread_1 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ClientManageThread_1 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ClientManageThread_1 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ClientManageThread_1 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ClientManageThread_1 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ClientManageThread_1 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ClientManageThread_1 java.lang.Thread.run(Thread.java:750) PullMessageThread_9 TID: 180 STATE: WAITING PullMessageThread_9 sun.misc.Unsafe.park(Native Method) PullMessageThread_9 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) PullMessageThread_9 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) PullMessageThread_9 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) PullMessageThread_9 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) PullMessageThread_9 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) PullMessageThread_9 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) PullMessageThread_9 java.lang.Thread.run(Thread.java:750) PopBufferMergeService TID: 81 STATE: TIMED_WAITING PopBufferMergeService sun.misc.Unsafe.park(Native Method) PopBufferMergeService java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) PopBufferMergeService java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037) PopBufferMergeService java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328) PopBufferMergeService org.apache.rocketmq.common.CountDownLatch2.await(CountDownLatch2.java:114) PopBufferMergeService org.apache.rocketmq.common.ServiceThread.waitForRunning(ServiceThread.java:117) PopBufferMergeService org.apache.rocketmq.broker.processor.PopBufferMergeService.run(PopBufferMergeService.java:110) PopBufferMergeService java.lang.Thread.run(Thread.java:750) AdminBrokerThread_12 TID: 208 STATE: WAITING AdminBrokerThread_12 sun.misc.Unsafe.park(Native Method) AdminBrokerThread_12 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) AdminBrokerThread_12 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) AdminBrokerThread_12 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) AdminBrokerThread_12 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) AdminBrokerThread_12 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) AdminBrokerThread_12 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) AdminBrokerThread_12 java.lang.Thread.run(Thread.java:750) ClientManageThread_26 TID: 267 STATE: WAITING ClientManageThread_26 sun.misc.Unsafe.park(Native Method) ClientManageThread_26 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ClientManageThread_26 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ClientManageThread_26 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ClientManageThread_26 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ClientManageThread_26 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ClientManageThread_26 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ClientManageThread_26 java.lang.Thread.run(Thread.java:750) ScheduleMessageTimerThread_11 TID: 113 STATE: WAITING ScheduleMessageTimerThread_11 sun.misc.Unsafe.park(Native Method) ScheduleMessageTimerThread_11 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ScheduleMessageTimerThread_11 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ScheduleMessageTimerThread_11 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088) ScheduleMessageTimerThread_11 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) ScheduleMessageTimerThread_11 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ScheduleMessageTimerThread_11 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ScheduleMessageTimerThread_11 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ScheduleMessageTimerThread_11 java.lang.Thread.run(Thread.java:750) HeartbeatThread_1 TID: 133 STATE: WAITING HeartbeatThread_1 sun.misc.Unsafe.park(Native Method) HeartbeatThread_1 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) HeartbeatThread_1 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) HeartbeatThread_1 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) HeartbeatThread_1 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) HeartbeatThread_1 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) HeartbeatThread_1 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) HeartbeatThread_1 java.lang.Thread.run(Thread.java:750) TopicRouteInfoManagerScheduledThread1 TID: 100 STATE: TIMED_WAITING TopicRouteInfoManagerScheduledThread1 sun.misc.Unsafe.park(Native Method) TopicRouteInfoManagerScheduledThread1 java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) TopicRouteInfoManagerScheduledThread1 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) TopicRouteInfoManagerScheduledThread1 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093) TopicRouteInfoManagerScheduledThread1 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) TopicRouteInfoManagerScheduledThread1 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) TopicRouteInfoManagerScheduledThread1 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) TopicRouteInfoManagerScheduledThread1 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) TopicRouteInfoManagerScheduledThread1 java.lang.Thread.run(Thread.java:750) ClientManageThread_31 TID: 272 STATE: WAITING ClientManageThread_31 sun.misc.Unsafe.park(Native Method) ClientManageThread_31 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ClientManageThread_31 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ClientManageThread_31 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ClientManageThread_31 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ClientManageThread_31 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ClientManageThread_31 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ClientManageThread_31 java.lang.Thread.run(Thread.java:750) TransactionalMessageCheckService TID: 122 STATE: TIMED_WAITING TransactionalMessageCheckService sun.misc.Unsafe.park(Native Method) TransactionalMessageCheckService java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) TransactionalMessageCheckService java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037) TransactionalMessageCheckService java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328) TransactionalMessageCheckService org.apache.rocketmq.common.CountDownLatch2.await(CountDownLatch2.java:114) TransactionalMessageCheckService org.apache.rocketmq.common.ServiceThread.waitForRunning(ServiceThread.java:117) TransactionalMessageCheckService org.apache.rocketmq.broker.transaction.TransactionalMessageCheckService.run(TransactionalMessageCheckService.java:47) TransactionalMessageCheckService java.lang.Thread.run(Thread.java:750) ScheduleMessageTimerThread_10 TID: 112 STATE: WAITING ScheduleMessageTimerThread_10 sun.misc.Unsafe.park(Native Method) ScheduleMessageTimerThread_10 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ScheduleMessageTimerThread_10 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ScheduleMessageTimerThread_10 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088) ScheduleMessageTimerThread_10 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) ScheduleMessageTimerThread_10 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ScheduleMessageTimerThread_10 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ScheduleMessageTimerThread_10 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ScheduleMessageTimerThread_10 java.lang.Thread.run(Thread.java:750) ClientManageThread_4 TID: 225 STATE: WAITING ClientManageThread_4 sun.misc.Unsafe.park(Native Method) ClientManageThread_4 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ClientManageThread_4 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ClientManageThread_4 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ClientManageThread_4 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ClientManageThread_4 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ClientManageThread_4 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ClientManageThread_4 java.lang.Thread.run(Thread.java:750) HAConnectionStateNotificationService TID: 56 STATE: TIMED_WAITING HAConnectionStateNotificationService sun.misc.Unsafe.park(Native Method) HAConnectionStateNotificationService java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) HAConnectionStateNotificationService java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037) HAConnectionStateNotificationService java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328) HAConnectionStateNotificationService org.apache.rocketmq.common.CountDownLatch2.await(CountDownLatch2.java:114) HAConnectionStateNotificationService org.apache.rocketmq.common.ServiceThread.waitForRunning(ServiceThread.java:117) HAConnectionStateNotificationService org.apache.rocketmq.store.ha.HAConnectionStateNotificationService.run(HAConnectionStateNotificationService.java:141) HAConnectionStateNotificationService java.lang.Thread.run(Thread.java:750) ScheduleMessageTimerThread_17 TID: 119 STATE: WAITING ScheduleMessageTimerThread_17 sun.misc.Unsafe.park(Native Method) ScheduleMessageTimerThread_17 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ScheduleMessageTimerThread_17 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ScheduleMessageTimerThread_17 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088) ScheduleMessageTimerThread_17 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) ScheduleMessageTimerThread_17 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ScheduleMessageTimerThread_17 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ScheduleMessageTimerThread_17 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ScheduleMessageTimerThread_17 java.lang.Thread.run(Thread.java:750) PullMessageThread_18 TID: 197 STATE: WAITING PullMessageThread_18 sun.misc.Unsafe.park(Native Method) PullMessageThread_18 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) PullMessageThread_18 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) PullMessageThread_18 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) PullMessageThread_18 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) PullMessageThread_18 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) PullMessageThread_18 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) PullMessageThread_18 java.lang.Thread.run(Thread.java:750) AdminBrokerThread_2 TID: 175 STATE: WAITING AdminBrokerThread_2 sun.misc.Unsafe.park(Native Method) AdminBrokerThread_2 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) AdminBrokerThread_2 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) AdminBrokerThread_2 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) AdminBrokerThread_2 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) AdminBrokerThread_2 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) AdminBrokerThread_2 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) AdminBrokerThread_2 java.lang.Thread.run(Thread.java:750) ScheduleMessageServicePersistThread1 TID: 121 STATE: TIMED_WAITING ScheduleMessageServicePersistThread1 sun.misc.Unsafe.park(Native Method) ScheduleMessageServicePersistThread1 java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) ScheduleMessageServicePersistThread1 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) ScheduleMessageServicePersistThread1 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093) ScheduleMessageServicePersistThread1 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) ScheduleMessageServicePersistThread1 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ScheduleMessageServicePersistThread1 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ScheduleMessageServicePersistThread1 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ScheduleMessageServicePersistThread1 java.lang.Thread.run(Thread.java:750) NettyClientPublicExecutor_1 TID: 126 STATE: WAITING NettyClientPublicExecutor_1 sun.misc.Unsafe.park(Native Method) NettyClientPublicExecutor_1 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) NettyClientPublicExecutor_1 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) NettyClientPublicExecutor_1 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) NettyClientPublicExecutor_1 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) NettyClientPublicExecutor_1 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) NettyClientPublicExecutor_1 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) NettyClientPublicExecutor_1 java.lang.Thread.run(Thread.java:750) TimerFlushService TID: 70 STATE: TIMED_WAITING TimerFlushService org.apache.rocketmq.store.timer.TimerWheel.getAllNum(TimerWheel.java:198) TimerFlushService org.apache.rocketmq.store.timer.TimerMessageStore.getAllCongestNum(TimerMessageStore.java:1693) TimerFlushService org.apache.rocketmq.store.timer.TimerMessageStore$TimerFlushService.run(TimerMessageStore.java:1680) TimerFlushService java.lang.Thread.run(Thread.java:750) SendMessageThread_1 TID: 198 STATE: WAITING SendMessageThread_1 sun.misc.Unsafe.park(Native Method) SendMessageThread_1 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) SendMessageThread_1 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) SendMessageThread_1 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) SendMessageThread_1 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) SendMessageThread_1 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) SendMessageThread_1 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) SendMessageThread_1 java.lang.Thread.run(Thread.java:750) AdminBrokerThread_8 TID: 184 STATE: WAITING AdminBrokerThread_8 sun.misc.Unsafe.park(Native Method) AdminBrokerThread_8 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) AdminBrokerThread_8 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) AdminBrokerThread_8 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) AdminBrokerThread_8 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) AdminBrokerThread_8 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) AdminBrokerThread_8 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) AdminBrokerThread_8 java.lang.Thread.run(Thread.java:750) AdminBrokerThread_4 TID: 177 STATE: WAITING AdminBrokerThread_4 sun.misc.Unsafe.park(Native Method) AdminBrokerThread_4 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) AdminBrokerThread_4 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) AdminBrokerThread_4 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) AdminBrokerThread_4 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) AdminBrokerThread_4 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) AdminBrokerThread_4 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) AdminBrokerThread_4 java.lang.Thread.run(Thread.java:750) TimerDequeuePutMessageService TID: 69 STATE: TIMED_WAITING TimerDequeuePutMessageService sun.misc.Unsafe.park(Native Method) TimerDequeuePutMessageService java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) TimerDequeuePutMessageService java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) TimerDequeuePutMessageService java.util.concurrent.LinkedBlockingDeque.pollFirst(LinkedBlockingDeque.java:522) TimerDequeuePutMessageService java.util.concurrent.LinkedBlockingDeque.poll(LinkedBlockingDeque.java:684) TimerDequeuePutMessageService org.apache.rocketmq.store.timer.TimerMessageStore$TimerDequeuePutMessageService.run(TimerMessageStore.java:1474) TimerDequeuePutMessageService java.lang.Thread.run(Thread.java:750) ConsumerManageThread_7 TID: 142 STATE: WAITING ConsumerManageThread_7 sun.misc.Unsafe.park(Native Method) ConsumerManageThread_7 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ConsumerManageThread_7 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ConsumerManageThread_7 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ConsumerManageThread_7 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ConsumerManageThread_7 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ConsumerManageThread_7 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ConsumerManageThread_7 java.lang.Thread.run(Thread.java:750) NettyServerNIOSelector_3 TID: 134 STATE: RUNNABLE NettyServerNIOSelector_3 sun.nio.ch.NativeThread.current(Native Method) NettyServerNIOSelector_3 sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:467) NettyServerNIOSelector_3 io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:408) NettyServerNIOSelector_3 io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:953) NettyServerNIOSelector_3 io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:354) NettyServerNIOSelector_3 io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:917) NettyServerNIOSelector_3 io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1372) NettyServerNIOSelector_3 io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:750) NettyServerNIOSelector_3 io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:742) NettyServerNIOSelector_3 io.netty.channel.AbstractChannelHandlerContext.access$2200(AbstractChannelHandlerContext.java:61) NettyServerNIOSelector_3 io.netty.channel.AbstractChannelHandlerContext$Tasks$4.run(AbstractChannelHandlerContext.java:1124) NettyServerNIOSelector_3 io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164) NettyServerNIOSelector_3 io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472) NettyServerNIOSelector_3 io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500) NettyServerNIOSelector_3 io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) NettyServerNIOSelector_3 io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) NettyServerNIOSelector_3 java.lang.Thread.run(Thread.java:750) ClientManageThread_9 TID: 230 STATE: WAITING ClientManageThread_9 sun.misc.Unsafe.park(Native Method) ClientManageThread_9 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ClientManageThread_9 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ClientManageThread_9 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ClientManageThread_9 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ClientManageThread_9 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ClientManageThread_9 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ClientManageThread_9 java.lang.Thread.run(Thread.java:750) BrokerControllerScheduledThread1 TID: 37 STATE: TIMED_WAITING BrokerControllerScheduledThread1 sun.misc.Unsafe.park(Native Method) BrokerControllerScheduledThread1 java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) BrokerControllerScheduledThread1 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) BrokerControllerScheduledThread1 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093) BrokerControllerScheduledThread1 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) BrokerControllerScheduledThread1 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) BrokerControllerScheduledThread1 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) BrokerControllerScheduledThread1 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) BrokerControllerScheduledThread1 java.lang.Thread.run(Thread.java:750) Reference Handler TID: 2 STATE: WAITING Reference Handler java.lang.Object.notifyAll(Native Method) Reference Handler java.lang.ref.ReferenceQueue.enqueue(ReferenceQueue.java:75) Reference Handler java.lang.ref.Reference.tryHandlePending(Reference.java:217) Reference Handler java.lang.ref.Reference$ReferenceHandler.run(Reference.java:153) PullMessageThread_5 TID: 172 STATE: WAITING PullMessageThread_5 sun.misc.Unsafe.park(Native Method) PullMessageThread_5 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) PullMessageThread_5 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) PullMessageThread_5 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) PullMessageThread_5 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) PullMessageThread_5 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) PullMessageThread_5 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) PullMessageThread_5 java.lang.Thread.run(Thread.java:750) ClientHousekeepingScheduledThread1 TID: 95 STATE: TIMED_WAITING ClientHousekeepingScheduledThread1 sun.misc.Unsafe.park(Native Method) ClientHousekeepingScheduledThread1 java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) ClientHousekeepingScheduledThread1 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) ClientHousekeepingScheduledThread1 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093) ClientHousekeepingScheduledThread1 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) ClientHousekeepingScheduledThread1 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ClientHousekeepingScheduledThread1 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ClientHousekeepingScheduledThread1 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ClientHousekeepingScheduledThread1 java.lang.Thread.run(Thread.java:750) FlushRealTimeService TID: 47 STATE: TIMED_WAITING FlushRealTimeService java.lang.Thread.sleep(Native Method) FlushRealTimeService org.apache.rocketmq.store.CommitLog$FlushRealTimeService.run(CommitLog.java:1515) FlushRealTimeService java.lang.Thread.run(Thread.java:750) logback-1 TID: 9 STATE: TIMED_WAITING logback-1 sun.misc.Unsafe.park(Native Method) logback-1 java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) logback-1 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) logback-1 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093) logback-1 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) logback-1 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) logback-1 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) logback-1 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) logback-1 java.lang.Thread.run(Thread.java:750) NettyServerCodecThread_4 TID: 220 STATE: WAITING NettyServerCodecThread_4 sun.misc.Unsafe.park(Native Method) NettyServerCodecThread_4 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) NettyServerCodecThread_4 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) NettyServerCodecThread_4 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) NettyServerCodecThread_4 io.netty.util.concurrent.SingleThreadEventExecutor.takeTask(SingleThreadEventExecutor.java:243) NettyServerCodecThread_4 io.netty.util.concurrent.DefaultEventExecutor.run(DefaultEventExecutor.java:64) NettyServerCodecThread_4 io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) NettyServerCodecThread_4 io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) NettyServerCodecThread_4 java.lang.Thread.run(Thread.java:750) ClientHouseKeepingService TID: 32 STATE: TIMED_WAITING ClientHouseKeepingService java.lang.Thread.sleep(Native Method) ClientHouseKeepingService io.netty.util.HashedWheelTimer$Worker.waitForNextTick(HashedWheelTimer.java:566) ClientHouseKeepingService io.netty.util.HashedWheelTimer$Worker.run(HashedWheelTimer.java:462) ClientHouseKeepingService java.lang.Thread.run(Thread.java:750) ClientManageThread_14 TID: 235 STATE: WAITING ClientManageThread_14 sun.misc.Unsafe.park(Native Method) ClientManageThread_14 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ClientManageThread_14 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ClientManageThread_14 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ClientManageThread_14 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ClientManageThread_14 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ClientManageThread_14 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ClientManageThread_14 java.lang.Thread.run(Thread.java:750) ScheduleMessageTimerThread_3 TID: 105 STATE: WAITING ScheduleMessageTimerThread_3 sun.misc.Unsafe.park(Native Method) ScheduleMessageTimerThread_3 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ScheduleMessageTimerThread_3 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ScheduleMessageTimerThread_3 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088) ScheduleMessageTimerThread_3 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) ScheduleMessageTimerThread_3 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ScheduleMessageTimerThread_3 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ScheduleMessageTimerThread_3 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ScheduleMessageTimerThread_3 java.lang.Thread.run(Thread.java:750) ClientManageThread_20 TID: 261 STATE: WAITING ClientManageThread_20 sun.misc.Unsafe.park(Native Method) ClientManageThread_20 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ClientManageThread_20 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ClientManageThread_20 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ClientManageThread_20 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ClientManageThread_20 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ClientManageThread_20 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ClientManageThread_20 java.lang.Thread.run(Thread.java:750) AsyncAppender-Worker-RocketmqBrokerMetricsSiftingAppenderTID: 26 STATE: WAITING AsyncAppender-Worker-RocketmqBrokerMetricsSiftingAppendersun.misc.Unsafe.park(Native Method) AsyncAppender-Worker-RocketmqBrokerMetricsSiftingAppenderjava.util.concurrent.locks.LockSupport.park(LockSupport.java:175) AsyncAppender-Worker-RocketmqBrokerMetricsSiftingAppenderjava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) AsyncAppender-Worker-RocketmqBrokerMetricsSiftingAppenderjava.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403) AsyncAppender-Worker-RocketmqBrokerMetricsSiftingAppenderorg.apache.rocketmq.logging.ch.qos.logback.core.AsyncAppenderBase$Worker.run(AsyncAppenderBase.java:298) QueryMessageThread_2 TID: 304 STATE: WAITING QueryMessageThread_2 sun.misc.Unsafe.park(Native Method) QueryMessageThread_2 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) QueryMessageThread_2 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) QueryMessageThread_2 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) QueryMessageThread_2 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) QueryMessageThread_2 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) QueryMessageThread_2 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) QueryMessageThread_2 java.lang.Thread.run(Thread.java:750) PopReviveService_3 TID: 86 STATE: TIMED_WAITING PopReviveService_3 java.lang.Thread.sleep(Native Method) PopReviveService_3 org.apache.rocketmq.broker.processor.PopReviveService.consumeReviveMessage(PopReviveService.java:333) PopReviveService_3 org.apache.rocketmq.broker.processor.PopReviveService.run(PopReviveService.java:637) PopReviveService_3 java.lang.Thread.run(Thread.java:750) ClientManageThread_30 TID: 271 STATE: WAITING ClientManageThread_30 sun.misc.Unsafe.park(Native Method) ClientManageThread_30 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ClientManageThread_30 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ClientManageThread_30 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ClientManageThread_30 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ClientManageThread_30 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ClientManageThread_30 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ClientManageThread_30 java.lang.Thread.run(Thread.java:750) ScheduleMessageTimerThread_9 TID: 111 STATE: WAITING ScheduleMessageTimerThread_9 sun.misc.Unsafe.park(Native Method) ScheduleMessageTimerThread_9 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ScheduleMessageTimerThread_9 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ScheduleMessageTimerThread_9 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088) ScheduleMessageTimerThread_9 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) ScheduleMessageTimerThread_9 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ScheduleMessageTimerThread_9 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ScheduleMessageTimerThread_9 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ScheduleMessageTimerThread_9 java.lang.Thread.run(Thread.java:750) NettyServerScheduler_1 TID: 75 STATE: TIMED_WAITING NettyServerScheduler_1 sun.misc.Unsafe.park(Native Method) NettyServerScheduler_1 java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) NettyServerScheduler_1 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) NettyServerScheduler_1 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093) NettyServerScheduler_1 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) NettyServerScheduler_1 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) NettyServerScheduler_1 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) NettyServerScheduler_1 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) NettyServerScheduler_1 java.lang.Thread.run(Thread.java:750) brokerOutApi_thread_1 TID: 123 STATE: WAITING brokerOutApi_thread_1 sun.misc.Unsafe.park(Native Method) brokerOutApi_thread_1 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) brokerOutApi_thread_1 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) brokerOutApi_thread_1 java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403) brokerOutApi_thread_1 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) brokerOutApi_thread_1 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) brokerOutApi_thread_1 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) brokerOutApi_thread_1 java.lang.Thread.run(Thread.java:750) NettyServerCodecThread_1 TID: 131 STATE: TIMED_WAITING NettyServerCodecThread_1 sun.misc.Unsafe.park(Native Method) NettyServerCodecThread_1 java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) NettyServerCodecThread_1 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) NettyServerCodecThread_1 java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467) NettyServerCodecThread_1 io.netty.util.concurrent.SingleThreadEventExecutor.takeTask(SingleThreadEventExecutor.java:256) NettyServerCodecThread_1 io.netty.util.concurrent.DefaultEventExecutor.run(DefaultEventExecutor.java:64) NettyServerCodecThread_1 io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) NettyServerCodecThread_1 io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) NettyServerCodecThread_1 java.lang.Thread.run(Thread.java:750) PopLongPollingService TID: 91 STATE: TIMED_WAITING PopLongPollingService sun.misc.Unsafe.park(Native Method) PopLongPollingService java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) PopLongPollingService java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037) PopLongPollingService java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328) PopLongPollingService org.apache.rocketmq.common.CountDownLatch2.await(CountDownLatch2.java:114) PopLongPollingService org.apache.rocketmq.common.ServiceThread.waitForRunning(ServiceThread.java:117) PopLongPollingService org.apache.rocketmq.broker.longpolling.PopLongPollingService.run(PopLongPollingService.java:77) PopLongPollingService java.lang.Thread.run(Thread.java:750) PullRequestHoldService TID: 94 STATE: TIMED_WAITING PullRequestHoldService sun.misc.Unsafe.park(Native Method) PullRequestHoldService java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) PullRequestHoldService java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037) PullRequestHoldService java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328) PullRequestHoldService org.apache.rocketmq.common.CountDownLatch2.await(CountDownLatch2.java:114) PullRequestHoldService org.apache.rocketmq.common.ServiceThread.waitForRunning(ServiceThread.java:117) PullRequestHoldService org.apache.rocketmq.broker.longpolling.PullRequestHoldService.run(PullRequestHoldService.java:73) PullRequestHoldService java.lang.Thread.run(Thread.java:750) AsyncAppender-Worker-RocketmqCommercialSiftingAppenderTID: 24 STATE: WAITING AsyncAppender-Worker-RocketmqCommercialSiftingAppendersun.misc.Unsafe.park(Native Method) AsyncAppender-Worker-RocketmqCommercialSiftingAppenderjava.util.concurrent.locks.LockSupport.park(LockSupport.java:175) AsyncAppender-Worker-RocketmqCommercialSiftingAppenderjava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) AsyncAppender-Worker-RocketmqCommercialSiftingAppenderjava.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403) AsyncAppender-Worker-RocketmqCommercialSiftingAppenderorg.apache.rocketmq.logging.ch.qos.logback.core.AsyncAppenderBase$Worker.run(AsyncAppenderBase.java:298) PullMessageThread_15 TID: 190 STATE: WAITING PullMessageThread_15 sun.misc.Unsafe.park(Native Method) PullMessageThread_15 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) PullMessageThread_15 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) PullMessageThread_15 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) PullMessageThread_15 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) PullMessageThread_15 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) PullMessageThread_15 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) PullMessageThread_15 java.lang.Thread.run(Thread.java:750) TransactionalOpBatchService TID: 38 STATE: TIMED_WAITING TransactionalOpBatchService sun.misc.Unsafe.park(Native Method) TransactionalOpBatchService java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) TransactionalOpBatchService java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037) TransactionalOpBatchService java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328) TransactionalOpBatchService org.apache.rocketmq.common.CountDownLatch2.await(CountDownLatch2.java:114) TransactionalOpBatchService org.apache.rocketmq.common.ServiceThread.waitForRunning(ServiceThread.java:117) TransactionalOpBatchService org.apache.rocketmq.broker.transaction.queue.TransactionalOpBatchService.run(TransactionalOpBatchService.java:56) TransactionalOpBatchService java.lang.Thread.run(Thread.java:750) ConsumerManageThread_4 TID: 139 STATE: WAITING ConsumerManageThread_4 sun.misc.Unsafe.defineClass(Native Method) ConsumerManageThread_4 sun.reflect.ClassDefiner.defineClass(ClassDefiner.java:63) ConsumerManageThread_4 sun.reflect.MethodAccessorGenerator$1.run(MethodAccessorGenerator.java:399) ConsumerManageThread_4 sun.reflect.MethodAccessorGenerator$1.run(MethodAccessorGenerator.java:394) ConsumerManageThread_4 java.security.AccessController.doPrivileged(Native Method) ConsumerManageThread_4 sun.reflect.MethodAccessorGenerator.generate(MethodAccessorGenerator.java:393) ConsumerManageThread_4 sun.reflect.MethodAccessorGenerator.generateConstructor(MethodAccessorGenerator.java:92) ConsumerManageThread_4 sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:55) ConsumerManageThread_4 sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) ConsumerManageThread_4 java.lang.reflect.Constructor.newInstance(Constructor.java:423) ConsumerManageThread_4 org.apache.rocketmq.remoting.protocol.RemotingCommand.createResponseCommand(RemotingCommand.java:159) ConsumerManageThread_4 org.apache.rocketmq.remoting.protocol.RemotingCommand.createResponseCommand(RemotingCommand.java:134) ConsumerManageThread_4 org.apache.rocketmq.broker.processor.ConsumerManageProcessor.updateConsumerOffset(ConsumerManageProcessor.java:148) ConsumerManageThread_4 org.apache.rocketmq.broker.processor.ConsumerManageProcessor.processRequest(ConsumerManageProcessor.java:65) ConsumerManageThread_4 org.apache.rocketmq.remoting.netty.NettyRemotingAbstract.lambda$buildProcessRequestHandler$1(NettyRemotingAbstract.java:331) ConsumerManageThread_4 org.apache.rocketmq.remoting.netty.NettyRemotingAbstract$$Lambda$140/1962033992.run(Unknown Source) ConsumerManageThread_4 org.apache.rocketmq.remoting.netty.RequestTask.run(RequestTask.java:80) ConsumerManageThread_4 java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ConsumerManageThread_4 java.util.concurrent.FutureTask.run(FutureTask.java:266) ConsumerManageThread_4 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ConsumerManageThread_4 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ConsumerManageThread_4 java.lang.Thread.run(Thread.java:750) ForkJoinPool.commonPool-worker-1 TID: 429 STATE: TIMED_WAITING ForkJoinPool.commonPool-worker-1 sun.misc.Unsafe.park(Native Method) ForkJoinPool.commonPool-worker-1 java.util.concurrent.ForkJoinPool.awaitWork(ForkJoinPool.java:1824) ForkJoinPool.commonPool-worker-1 java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1693) ForkJoinPool.commonPool-worker-1 java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175) AsyncAppender-Worker-RocketmqStoreSiftingAppenderTID: 15 STATE: WAITING AsyncAppender-Worker-RocketmqStoreSiftingAppendersun.misc.Unsafe.park(Native Method) AsyncAppender-Worker-RocketmqStoreSiftingAppenderjava.util.concurrent.locks.LockSupport.park(LockSupport.java:175) AsyncAppender-Worker-RocketmqStoreSiftingAppenderjava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) AsyncAppender-Worker-RocketmqStoreSiftingAppenderjava.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403) AsyncAppender-Worker-RocketmqStoreSiftingAppenderorg.apache.rocketmq.logging.ch.qos.logback.core.AsyncAppenderBase$Worker.run(AsyncAppenderBase.java:298) ClientManageThread_7 TID: 228 STATE: WAITING ClientManageThread_7 sun.misc.Unsafe.park(Native Method) ClientManageThread_7 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ClientManageThread_7 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ClientManageThread_7 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ClientManageThread_7 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ClientManageThread_7 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ClientManageThread_7 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ClientManageThread_7 java.lang.Thread.run(Thread.java:750) NettyClientWorkerThread_3 TID: 99 STATE: TIMED_WAITING NettyClientWorkerThread_3 sun.misc.Unsafe.park(Native Method) NettyClientWorkerThread_3 java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) NettyClientWorkerThread_3 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) NettyClientWorkerThread_3 java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467) NettyClientWorkerThread_3 io.netty.util.concurrent.SingleThreadEventExecutor.takeTask(SingleThreadEventExecutor.java:256) NettyClientWorkerThread_3 io.netty.util.concurrent.DefaultEventExecutor.run(DefaultEventExecutor.java:64) NettyClientWorkerThread_3 io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) NettyClientWorkerThread_3 io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) NettyClientWorkerThread_3 java.lang.Thread.run(Thread.java:750) AsyncAppender-Worker-RocketmqRocksDBSiftingAppenderTID: 14 STATE: WAITING AsyncAppender-Worker-RocketmqRocksDBSiftingAppendersun.misc.Unsafe.park(Native Method) AsyncAppender-Worker-RocketmqRocksDBSiftingAppenderjava.util.concurrent.locks.LockSupport.park(LockSupport.java:175) AsyncAppender-Worker-RocketmqRocksDBSiftingAppenderjava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) AsyncAppender-Worker-RocketmqRocksDBSiftingAppenderjava.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403) AsyncAppender-Worker-RocketmqRocksDBSiftingAppenderorg.apache.rocketmq.logging.ch.qos.logback.core.AsyncAppenderBase$Worker.run(AsyncAppenderBase.java:298) brokerOutApi_thread_2 TID: 124 STATE: WAITING brokerOutApi_thread_2 sun.misc.Unsafe.park(Native Method) brokerOutApi_thread_2 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) brokerOutApi_thread_2 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) brokerOutApi_thread_2 java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403) brokerOutApi_thread_2 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) brokerOutApi_thread_2 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) brokerOutApi_thread_2 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) brokerOutApi_thread_2 java.lang.Thread.run(Thread.java:750) NettyNIOBoss_1 TID: 76 STATE: RUNNABLE NettyNIOBoss_1 sun.nio.ch.EPollArrayWrapper.epollWait(Native Method) NettyNIOBoss_1 sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269) NettyNIOBoss_1 sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93) NettyNIOBoss_1 sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86) NettyNIOBoss_1 sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97) NettyNIOBoss_1 sun.nio.ch.SelectorImpl.select(SelectorImpl.java:101) NettyNIOBoss_1 io.netty.channel.nio.SelectedSelectionKeySetSelector.select(SelectedSelectionKeySetSelector.java:68) NettyNIOBoss_1 io.netty.channel.nio.NioEventLoop.select(NioEventLoop.java:810) NettyNIOBoss_1 io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:457) NettyNIOBoss_1 io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) NettyNIOBoss_1 io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) NettyNIOBoss_1 java.lang.Thread.run(Thread.java:750) PopReviveService_7 TID: 90 STATE: TIMED_WAITING PopReviveService_7 java.lang.Thread.sleep(Native Method) PopReviveService_7 org.apache.rocketmq.broker.processor.PopReviveService.consumeReviveMessage(PopReviveService.java:333) PopReviveService_7 org.apache.rocketmq.broker.processor.PopReviveService.run(PopReviveService.java:637) PopReviveService_7 java.lang.Thread.run(Thread.java:750) PullMessageThread_7 TID: 178 STATE: WAITING PullMessageThread_7 sun.misc.Unsafe.park(Native Method) PullMessageThread_7 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) PullMessageThread_7 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) PullMessageThread_7 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) PullMessageThread_7 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) PullMessageThread_7 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) PullMessageThread_7 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) PullMessageThread_7 java.lang.Thread.run(Thread.java:750) ScheduleMessageTimerThread_15 TID: 117 STATE: WAITING ScheduleMessageTimerThread_15 sun.misc.Unsafe.park(Native Method) ScheduleMessageTimerThread_15 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ScheduleMessageTimerThread_15 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ScheduleMessageTimerThread_15 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088) ScheduleMessageTimerThread_15 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) ScheduleMessageTimerThread_15 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ScheduleMessageTimerThread_15 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ScheduleMessageTimerThread_15 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ScheduleMessageTimerThread_15 java.lang.Thread.run(Thread.java:750) AsyncAppender-Worker-RocketmqStoreErrorSiftingAppenderTID: 19 STATE: WAITING AsyncAppender-Worker-RocketmqStoreErrorSiftingAppendersun.misc.Unsafe.park(Native Method) AsyncAppender-Worker-RocketmqStoreErrorSiftingAppenderjava.util.concurrent.locks.LockSupport.park(LockSupport.java:175) AsyncAppender-Worker-RocketmqStoreErrorSiftingAppenderjava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) AsyncAppender-Worker-RocketmqStoreErrorSiftingAppenderjava.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403) AsyncAppender-Worker-RocketmqStoreErrorSiftingAppenderorg.apache.rocketmq.logging.ch.qos.logback.core.AsyncAppenderBase$Worker.run(AsyncAppenderBase.java:298) ConsumerManageThread_8 TID: 143 STATE: WAITING ConsumerManageThread_8 java.lang.Class.getDeclaredConstructors0(Native Method) ConsumerManageThread_8 java.lang.Class.privateGetDeclaredConstructors(Class.java:2671) ConsumerManageThread_8 java.lang.Class.getConstructor0(Class.java:3075) ConsumerManageThread_8 java.lang.Class.newInstance(Class.java:412) ConsumerManageThread_8 sun.reflect.MethodAccessorGenerator$1.run(MethodAccessorGenerator.java:403) ConsumerManageThread_8 sun.reflect.MethodAccessorGenerator$1.run(MethodAccessorGenerator.java:394) ConsumerManageThread_8 java.security.AccessController.doPrivileged(Native Method) ConsumerManageThread_8 sun.reflect.MethodAccessorGenerator.generate(MethodAccessorGenerator.java:393) ConsumerManageThread_8 sun.reflect.MethodAccessorGenerator.generateConstructor(MethodAccessorGenerator.java:92) ConsumerManageThread_8 sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:55) ConsumerManageThread_8 sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) ConsumerManageThread_8 java.lang.reflect.Constructor.newInstance(Constructor.java:423) ConsumerManageThread_8 org.apache.rocketmq.remoting.protocol.RemotingCommand.createResponseCommand(RemotingCommand.java:159) ConsumerManageThread_8 org.apache.rocketmq.remoting.protocol.RemotingCommand.createResponseCommand(RemotingCommand.java:134) ConsumerManageThread_8 org.apache.rocketmq.broker.processor.ConsumerManageProcessor.updateConsumerOffset(ConsumerManageProcessor.java:148) ConsumerManageThread_8 org.apache.rocketmq.broker.processor.ConsumerManageProcessor.processRequest(ConsumerManageProcessor.java:65) ConsumerManageThread_8 org.apache.rocketmq.remoting.netty.NettyRemotingAbstract.lambda$buildProcessRequestHandler$1(NettyRemotingAbstract.java:331) ConsumerManageThread_8 org.apache.rocketmq.remoting.netty.NettyRemotingAbstract$$Lambda$140/1962033992.run(Unknown Source) ConsumerManageThread_8 org.apache.rocketmq.remoting.netty.RequestTask.run(RequestTask.java:80) ConsumerManageThread_8 java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ConsumerManageThread_8 java.util.concurrent.FutureTask.run(FutureTask.java:266) ConsumerManageThread_8 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ConsumerManageThread_8 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ConsumerManageThread_8 java.lang.Thread.run(Thread.java:750) ClientManageThread_2 TID: 223 STATE: WAITING ClientManageThread_2 sun.misc.Unsafe.park(Native Method) ClientManageThread_2 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ClientManageThread_2 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ClientManageThread_2 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ClientManageThread_2 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ClientManageThread_2 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ClientManageThread_2 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ClientManageThread_2 java.lang.Thread.run(Thread.java:750) ConsumerManageThread_18 TID: 153 STATE: WAITING ConsumerManageThread_18 sun.misc.Unsafe.park(Native Method) ConsumerManageThread_18 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ConsumerManageThread_18 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ConsumerManageThread_18 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ConsumerManageThread_18 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ConsumerManageThread_18 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ConsumerManageThread_18 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ConsumerManageThread_18 java.lang.Thread.run(Thread.java:750) BrokerStatsThread1 TID: 28 STATE: TIMED_WAITING BrokerStatsThread1 sun.misc.Unsafe.park(Native Method) BrokerStatsThread1 java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) BrokerStatsThread1 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) BrokerStatsThread1 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093) BrokerStatsThread1 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) BrokerStatsThread1 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) BrokerStatsThread1 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) BrokerStatsThread1 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) BrokerStatsThread1 java.lang.Thread.run(Thread.java:750) ConsumerManageThread_10 TID: 145 STATE: WAITING ConsumerManageThread_10 sun.misc.Unsafe.park(Native Method) ConsumerManageThread_10 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ConsumerManageThread_10 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ConsumerManageThread_10 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ConsumerManageThread_10 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ConsumerManageThread_10 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ConsumerManageThread_10 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ConsumerManageThread_10 java.lang.Thread.run(Thread.java:750) FlushDiskWatcher TID: 48 STATE: WAITING FlushDiskWatcher sun.misc.Unsafe.park(Native Method) FlushDiskWatcher java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) FlushDiskWatcher java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) FlushDiskWatcher java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) FlushDiskWatcher org.apache.rocketmq.store.FlushDiskWatcher.run(FlushDiskWatcher.java:42) FlushDiskWatcher java.lang.Thread.run(Thread.java:750) ConsumerManageThread_30 TID: 165 STATE: WAITING ConsumerManageThread_30 sun.misc.Unsafe.defineClass(Native Method) ConsumerManageThread_30 sun.reflect.ClassDefiner.defineClass(ClassDefiner.java:63) ConsumerManageThread_30 sun.reflect.MethodAccessorGenerator$1.run(MethodAccessorGenerator.java:399) ConsumerManageThread_30 sun.reflect.MethodAccessorGenerator$1.run(MethodAccessorGenerator.java:394) ConsumerManageThread_30 java.security.AccessController.doPrivileged(Native Method) ConsumerManageThread_30 sun.reflect.MethodAccessorGenerator.generate(MethodAccessorGenerator.java:393) ConsumerManageThread_30 sun.reflect.MethodAccessorGenerator.generateConstructor(MethodAccessorGenerator.java:92) ConsumerManageThread_30 sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:55) ConsumerManageThread_30 sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) ConsumerManageThread_30 java.lang.reflect.Constructor.newInstance(Constructor.java:423) ConsumerManageThread_30 org.apache.rocketmq.remoting.protocol.RemotingCommand.createResponseCommand(RemotingCommand.java:159) ConsumerManageThread_30 org.apache.rocketmq.remoting.protocol.RemotingCommand.createResponseCommand(RemotingCommand.java:134) ConsumerManageThread_30 org.apache.rocketmq.broker.processor.ConsumerManageProcessor.updateConsumerOffset(ConsumerManageProcessor.java:148) ConsumerManageThread_30 org.apache.rocketmq.broker.processor.ConsumerManageProcessor.processRequest(ConsumerManageProcessor.java:65) ConsumerManageThread_30 org.apache.rocketmq.remoting.netty.NettyRemotingAbstract.lambda$buildProcessRequestHandler$1(NettyRemotingAbstract.java:331) ConsumerManageThread_30 org.apache.rocketmq.remoting.netty.NettyRemotingAbstract$$Lambda$140/1962033992.run(Unknown Source) ConsumerManageThread_30 org.apache.rocketmq.remoting.netty.RequestTask.run(RequestTask.java:80) ConsumerManageThread_30 java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ConsumerManageThread_30 java.util.concurrent.FutureTask.run(FutureTask.java:266) ConsumerManageThread_30 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ConsumerManageThread_30 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ConsumerManageThread_30 java.lang.Thread.run(Thread.java:750) PopReviveService_5 TID: 88 STATE: TIMED_WAITING PopReviveService_5 java.lang.Thread.sleep(Native Method) PopReviveService_5 org.apache.rocketmq.broker.processor.PopReviveService.consumeReviveMessage(PopReviveService.java:333) PopReviveService_5 org.apache.rocketmq.broker.processor.PopReviveService.run(PopReviveService.java:637) PopReviveService_5 java.lang.Thread.run(Thread.java:750) StoreScheduledThread1 TID: 57 STATE: TIMED_WAITING StoreScheduledThread1 sun.misc.Unsafe.park(Native Method) StoreScheduledThread1 java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) StoreScheduledThread1 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) StoreScheduledThread1 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093) StoreScheduledThread1 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) StoreScheduledThread1 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) StoreScheduledThread1 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) StoreScheduledThread1 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) StoreScheduledThread1 java.lang.Thread.run(Thread.java:750) ColdDataPullRequestHoldService TID: 101 STATE: TIMED_WAITING ColdDataPullRequestHoldService sun.misc.Unsafe.park(Native Method) ColdDataPullRequestHoldService java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) ColdDataPullRequestHoldService java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037) ColdDataPullRequestHoldService java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328) ColdDataPullRequestHoldService org.apache.rocketmq.common.CountDownLatch2.await(CountDownLatch2.java:114) ColdDataPullRequestHoldService org.apache.rocketmq.common.ServiceThread.waitForRunning(ServiceThread.java:117) ColdDataPullRequestHoldService org.apache.rocketmq.broker.coldctr.ColdDataPullRequestHoldService.run(ColdDataPullRequestHoldService.java:67) ColdDataPullRequestHoldService java.lang.Thread.run(Thread.java:750) ReputMessageService TID: 45 STATE: TIMED_WAITING ReputMessageService java.lang.Thread.sleep(Native Method) ReputMessageService java.lang.Thread.sleep(Thread.java:342) ReputMessageService java.util.concurrent.TimeUnit.sleep(TimeUnit.java:386) ReputMessageService org.apache.rocketmq.store.DefaultMessageStore$ReputMessageService.run(DefaultMessageStore.java:2927) ReputMessageService java.lang.Thread.run(Thread.java:750) ClientManageThread_32 TID: 273 STATE: WAITING ClientManageThread_32 sun.misc.Unsafe.park(Native Method) ClientManageThread_32 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ClientManageThread_32 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ClientManageThread_32 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ClientManageThread_32 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ClientManageThread_32 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ClientManageThread_32 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ClientManageThread_32 java.lang.Thread.run(Thread.java:750) NettyClientWorkerThread_2 TID: 98 STATE: TIMED_WAITING NettyClientWorkerThread_2 sun.misc.Unsafe.park(Native Method) NettyClientWorkerThread_2 java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) NettyClientWorkerThread_2 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) NettyClientWorkerThread_2 java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467) NettyClientWorkerThread_2 io.netty.util.concurrent.SingleThreadEventExecutor.takeTask(SingleThreadEventExecutor.java:256) NettyClientWorkerThread_2 io.netty.util.concurrent.DefaultEventExecutor.run(DefaultEventExecutor.java:64) NettyClientWorkerThread_2 io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) NettyClientWorkerThread_2 io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) NettyClientWorkerThread_2 java.lang.Thread.run(Thread.java:750) ServerHouseKeepingService TID: 36 STATE: TIMED_WAITING ServerHouseKeepingService java.lang.Thread.sleep(Native Method) ServerHouseKeepingService io.netty.util.HashedWheelTimer$Worker.waitForNextTick(HashedWheelTimer.java:566) ServerHouseKeepingService io.netty.util.HashedWheelTimer$Worker.run(HashedWheelTimer.java:462) ServerHouseKeepingService java.lang.Thread.run(Thread.java:750) PullMessageThread_2 TID: 169 STATE: WAITING PullMessageThread_2 sun.misc.Unsafe.park(Native Method) PullMessageThread_2 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) PullMessageThread_2 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) PullMessageThread_2 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) PullMessageThread_2 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) PullMessageThread_2 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) PullMessageThread_2 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) PullMessageThread_2 java.lang.Thread.run(Thread.java:750) PopReviveService_0 TID: 83 STATE: TIMED_WAITING PopReviveService_0 java.lang.Thread.sleep(Native Method) PopReviveService_0 org.apache.rocketmq.broker.processor.PopReviveService.consumeReviveMessage(PopReviveService.java:333) PopReviveService_0 org.apache.rocketmq.broker.processor.PopReviveService.run(PopReviveService.java:637) PopReviveService_0 java.lang.Thread.run(Thread.java:750) QueryMessageThread_3 TID: 305 STATE: WAITING QueryMessageThread_3 sun.misc.Unsafe.park(Native Method) QueryMessageThread_3 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) QueryMessageThread_3 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) QueryMessageThread_3 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) QueryMessageThread_3 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) QueryMessageThread_3 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) QueryMessageThread_3 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) QueryMessageThread_3 java.lang.Thread.run(Thread.java:750) PopReviveService_1 TID: 84 STATE: TIMED_WAITING PopReviveService_1 java.lang.Thread.sleep(Native Method) PopReviveService_1 org.apache.rocketmq.broker.processor.PopReviveService.consumeReviveMessage(PopReviveService.java:333) PopReviveService_1 org.apache.rocketmq.broker.processor.PopReviveService.run(PopReviveService.java:637) PopReviveService_1 java.lang.Thread.run(Thread.java:750) WriteSocketService TID: 217 STATE: TIMED_WAITING WriteSocketService java.lang.Object.wait(Native Method) WriteSocketService org.apache.rocketmq.store.ha.WaitNotifyObject.allWaitForRunning(WaitNotifyObject.java:96) WriteSocketService org.apache.rocketmq.store.ha.DefaultHAConnection$WriteSocketService.run(DefaultHAConnection.java:368) WriteSocketService java.lang.Thread.run(Thread.java:750) ConsumerManageThread_25 TID: 160 STATE: WAITING ConsumerManageThread_25 sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) ConsumerManageThread_25 java.lang.reflect.Constructor.newInstance(Constructor.java:423) ConsumerManageThread_25 org.apache.rocketmq.remoting.protocol.RemotingCommand.createResponseCommand(RemotingCommand.java:159) ConsumerManageThread_25 org.apache.rocketmq.remoting.protocol.RemotingCommand.createResponseCommand(RemotingCommand.java:134) ConsumerManageThread_25 org.apache.rocketmq.broker.processor.ConsumerManageProcessor.updateConsumerOffset(ConsumerManageProcessor.java:148) ConsumerManageThread_25 org.apache.rocketmq.broker.processor.ConsumerManageProcessor.processRequest(ConsumerManageProcessor.java:65) ConsumerManageThread_25 org.apache.rocketmq.remoting.netty.NettyRemotingAbstract.lambda$buildProcessRequestHandler$1(NettyRemotingAbstract.java:331) ConsumerManageThread_25 org.apache.rocketmq.remoting.netty.NettyRemotingAbstract$$Lambda$140/1962033992.run(Unknown Source) ConsumerManageThread_25 org.apache.rocketmq.remoting.netty.RequestTask.run(RequestTask.java:80) ConsumerManageThread_25 java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ConsumerManageThread_25 java.util.concurrent.FutureTask.run(FutureTask.java:266) ConsumerManageThread_25 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ConsumerManageThread_25 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ConsumerManageThread_25 java.lang.Thread.run(Thread.java:750) org.apache.rocketmq.store.util.PerfCounter$TicksTID: 59 STATE: TIMED_WAITING org.apache.rocketmq.store.util.PerfCounter$Tickssun.misc.Unsafe.park(Native Method) org.apache.rocketmq.store.util.PerfCounter$Ticksjava.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) org.apache.rocketmq.store.util.PerfCounter$Ticksjava.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037) org.apache.rocketmq.store.util.PerfCounter$Ticksjava.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328) org.apache.rocketmq.store.util.PerfCounter$Ticksorg.apache.rocketmq.common.CountDownLatch2.await(CountDownLatch2.java:114) org.apache.rocketmq.store.util.PerfCounter$Ticksorg.apache.rocketmq.common.ServiceThread.waitForRunning(ServiceThread.java:117) org.apache.rocketmq.store.util.PerfCounter$Ticksorg.apache.rocketmq.store.util.PerfCounter$Ticks.run(PerfCounter.java:329) org.apache.rocketmq.store.util.PerfCounter$Ticksjava.lang.Thread.run(Thread.java:750) AdminBrokerThread_6 TID: 182 STATE: WAITING AdminBrokerThread_6 sun.misc.Unsafe.park(Native Method) AdminBrokerThread_6 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) AdminBrokerThread_6 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) AdminBrokerThread_6 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) AdminBrokerThread_6 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) AdminBrokerThread_6 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) AdminBrokerThread_6 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) AdminBrokerThread_6 java.lang.Thread.run(Thread.java:750) TimerScheduledThread1 TID: 71 STATE: TIMED_WAITING TimerScheduledThread1 sun.misc.Unsafe.park(Native Method) TimerScheduledThread1 java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) TimerScheduledThread1 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) TimerScheduledThread1 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093) TimerScheduledThread1 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) TimerScheduledThread1 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) TimerScheduledThread1 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) TimerScheduledThread1 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) TimerScheduledThread1 java.lang.Thread.run(Thread.java:750) PullMessageThread_11 TID: 186 STATE: WAITING PullMessageThread_11 sun.misc.Unsafe.park(Native Method) PullMessageThread_11 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) PullMessageThread_11 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) PullMessageThread_11 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) PullMessageThread_11 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) PullMessageThread_11 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) PullMessageThread_11 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) PullMessageThread_11 java.lang.Thread.run(Thread.java:750) ClientManageThread_28 TID: 269 STATE: WAITING ClientManageThread_28 sun.misc.Unsafe.park(Native Method) ClientManageThread_28 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ClientManageThread_28 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ClientManageThread_28 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ClientManageThread_28 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ClientManageThread_28 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ClientManageThread_28 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ClientManageThread_28 java.lang.Thread.run(Thread.java:750) PullMessageThread_13 TID: 188 STATE: WAITING PullMessageThread_13 sun.misc.Unsafe.park(Native Method) PullMessageThread_13 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) PullMessageThread_13 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) PullMessageThread_13 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) PullMessageThread_13 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) PullMessageThread_13 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) PullMessageThread_13 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) PullMessageThread_13 java.lang.Thread.run(Thread.java:750) ClientManageThread_23 TID: 264 STATE: WAITING ClientManageThread_23 sun.misc.Unsafe.park(Native Method) ClientManageThread_23 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ClientManageThread_23 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ClientManageThread_23 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ClientManageThread_23 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ClientManageThread_23 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ClientManageThread_23 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ClientManageThread_23 java.lang.Thread.run(Thread.java:750) NettyClientWorkerThread_1 TID: 79 STATE: TIMED_WAITING NettyClientWorkerThread_1 sun.misc.Unsafe.park(Native Method) NettyClientWorkerThread_1 java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) NettyClientWorkerThread_1 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) NettyClientWorkerThread_1 java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467) NettyClientWorkerThread_1 io.netty.util.concurrent.SingleThreadEventExecutor.takeTask(SingleThreadEventExecutor.java:256) NettyClientWorkerThread_1 io.netty.util.concurrent.DefaultEventExecutor.run(DefaultEventExecutor.java:64) NettyClientWorkerThread_1 io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) NettyClientWorkerThread_1 io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) NettyClientWorkerThread_1 java.lang.Thread.run(Thread.java:750) NettyServerNIOSelector_2 TID: 130 STATE: RUNNABLE NettyServerNIOSelector_2 sun.nio.ch.EPollArrayWrapper.epollWait(Native Method) NettyServerNIOSelector_2 sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269) NettyServerNIOSelector_2 sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93) NettyServerNIOSelector_2 sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86) NettyServerNIOSelector_2 sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97) NettyServerNIOSelector_2 sun.nio.ch.SelectorImpl.select(SelectorImpl.java:101) NettyServerNIOSelector_2 io.netty.channel.nio.SelectedSelectionKeySetSelector.select(SelectedSelectionKeySetSelector.java:68) NettyServerNIOSelector_2 io.netty.channel.nio.NioEventLoop.select(NioEventLoop.java:810) NettyServerNIOSelector_2 io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:457) NettyServerNIOSelector_2 io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) NettyServerNIOSelector_2 io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) NettyServerNIOSelector_2 java.lang.Thread.run(Thread.java:750) TimerEnqueuePutService TID: 61 STATE: TIMED_WAITING TimerEnqueuePutService sun.misc.Unsafe.park(Native Method) TimerEnqueuePutService java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) TimerEnqueuePutService java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) TimerEnqueuePutService java.util.concurrent.LinkedBlockingDeque.pollFirst(LinkedBlockingDeque.java:522) TimerEnqueuePutService java.util.concurrent.LinkedBlockingDeque.poll(LinkedBlockingDeque.java:684) TimerEnqueuePutService org.apache.rocketmq.store.timer.TimerMessageStore$TimerEnqueuePutService.fetchTimerRequests(TimerMessageStore.java:1337) TimerEnqueuePutService org.apache.rocketmq.store.timer.TimerMessageStore$TimerEnqueuePutService.fetchAndPutTimerRequest(TimerMessageStore.java:1380) TimerEnqueuePutService org.apache.rocketmq.store.timer.TimerMessageStore$TimerEnqueuePutService.run(TimerMessageStore.java:1410) TimerEnqueuePutService java.lang.Thread.run(Thread.java:750) AsyncAppender-Worker-RocketmqStatsSiftingAppenderTID: 23 STATE: WAITING AsyncAppender-Worker-RocketmqStatsSiftingAppendersun.misc.Unsafe.park(Native Method) AsyncAppender-Worker-RocketmqStatsSiftingAppenderjava.util.concurrent.locks.LockSupport.park(LockSupport.java:175) AsyncAppender-Worker-RocketmqStatsSiftingAppenderjava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) AsyncAppender-Worker-RocketmqStatsSiftingAppenderjava.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403) AsyncAppender-Worker-RocketmqStatsSiftingAppenderorg.apache.rocketmq.logging.ch.qos.logback.core.AsyncAppenderBase$Worker.run(AsyncAppenderBase.java:298) ConsumerManageThread_13 TID: 148 STATE: WAITING ConsumerManageThread_13 sun.misc.Unsafe.park(Native Method) ConsumerManageThread_13 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ConsumerManageThread_13 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ConsumerManageThread_13 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ConsumerManageThread_13 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ConsumerManageThread_13 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ConsumerManageThread_13 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ConsumerManageThread_13 java.lang.Thread.run(Thread.java:750) ClientManageThread_8 TID: 229 STATE: WAITING ClientManageThread_8 sun.misc.Unsafe.park(Native Method) ClientManageThread_8 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ClientManageThread_8 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ClientManageThread_8 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ClientManageThread_8 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ClientManageThread_8 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ClientManageThread_8 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ClientManageThread_8 java.lang.Thread.run(Thread.java:750) PopReviveService_2 TID: 85 STATE: TIMED_WAITING PopReviveService_2 java.lang.Thread.sleep(Native Method) PopReviveService_2 org.apache.rocketmq.broker.processor.PopReviveService.consumeReviveMessage(PopReviveService.java:333) PopReviveService_2 org.apache.rocketmq.broker.processor.PopReviveService.run(PopReviveService.java:637) PopReviveService_2 java.lang.Thread.run(Thread.java:750) NettyServerCodecThread_5 TID: 236 STATE: WAITING NettyServerCodecThread_5 sun.misc.Unsafe.park(Native Method) NettyServerCodecThread_5 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) NettyServerCodecThread_5 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) NettyServerCodecThread_5 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) NettyServerCodecThread_5 io.netty.util.concurrent.SingleThreadEventExecutor.takeTask(SingleThreadEventExecutor.java:243) NettyServerCodecThread_5 io.netty.util.concurrent.DefaultEventExecutor.run(DefaultEventExecutor.java:64) NettyServerCodecThread_5 io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) NettyServerCodecThread_5 io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) NettyServerCodecThread_5 java.lang.Thread.run(Thread.java:750) ConsumerManageThread_31 TID: 166 STATE: WAITING ConsumerManageThread_31 sun.misc.Unsafe.park(Native Method) ConsumerManageThread_31 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ConsumerManageThread_31 java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:836) ConsumerManageThread_31 java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireInterruptibly(AbstractQueuedSynchronizer.java:897) ConsumerManageThread_31 java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireInterruptibly(AbstractQueuedSynchronizer.java:1222) ConsumerManageThread_31 java.util.concurrent.locks.ReentrantLock.lockInterruptibly(ReentrantLock.java:335) ConsumerManageThread_31 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:439) ConsumerManageThread_31 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ConsumerManageThread_31 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ConsumerManageThread_31 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ConsumerManageThread_31 java.lang.Thread.run(Thread.java:750) AsyncAppender-Worker-RocketmqTrafficSiftingAppenderTID: 17 STATE: WAITING AsyncAppender-Worker-RocketmqTrafficSiftingAppendersun.misc.Unsafe.park(Native Method) AsyncAppender-Worker-RocketmqTrafficSiftingAppenderjava.util.concurrent.locks.LockSupport.park(LockSupport.java:175) AsyncAppender-Worker-RocketmqTrafficSiftingAppenderjava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) AsyncAppender-Worker-RocketmqTrafficSiftingAppenderjava.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403) AsyncAppender-Worker-RocketmqTrafficSiftingAppenderorg.apache.rocketmq.logging.ch.qos.logback.core.AsyncAppenderBase$Worker.run(AsyncAppenderBase.java:298) AsyncAppender-Worker-RocketmqTieredStoreSiftingAppenderTID: 16 STATE: WAITING AsyncAppender-Worker-RocketmqTieredStoreSiftingAppendersun.misc.Unsafe.park(Native Method) AsyncAppender-Worker-RocketmqTieredStoreSiftingAppenderjava.util.concurrent.locks.LockSupport.park(LockSupport.java:175) AsyncAppender-Worker-RocketmqTieredStoreSiftingAppenderjava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) AsyncAppender-Worker-RocketmqTieredStoreSiftingAppenderjava.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403) AsyncAppender-Worker-RocketmqTieredStoreSiftingAppenderorg.apache.rocketmq.logging.ch.qos.logback.core.AsyncAppenderBase$Worker.run(AsyncAppenderBase.java:298) PullMessageThread_3 TID: 170 STATE: WAITING PullMessageThread_3 sun.misc.Unsafe.park(Native Method) PullMessageThread_3 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) PullMessageThread_3 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) PullMessageThread_3 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) PullMessageThread_3 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) PullMessageThread_3 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) PullMessageThread_3 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) PullMessageThread_3 java.lang.Thread.run(Thread.java:750) NettyServerCodecThread_6 TID: 201 STATE: TIMED_WAITING NettyServerCodecThread_6 sun.misc.Unsafe.park(Native Method) NettyServerCodecThread_6 java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) NettyServerCodecThread_6 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) NettyServerCodecThread_6 java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467) NettyServerCodecThread_6 io.netty.util.concurrent.SingleThreadEventExecutor.takeTask(SingleThreadEventExecutor.java:256) NettyServerCodecThread_6 io.netty.util.concurrent.DefaultEventExecutor.run(DefaultEventExecutor.java:64) NettyServerCodecThread_6 io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) NettyServerCodecThread_6 io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) NettyServerCodecThread_6 java.lang.Thread.run(Thread.java:750) CommercialStatsThread1 TID: 29 STATE: TIMED_WAITING CommercialStatsThread1 sun.misc.Unsafe.park(Native Method) CommercialStatsThread1 java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) CommercialStatsThread1 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) CommercialStatsThread1 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093) CommercialStatsThread1 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) CommercialStatsThread1 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) CommercialStatsThread1 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) CommercialStatsThread1 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) CommercialStatsThread1 java.lang.Thread.run(Thread.java:750) AdminBrokerThread_16 TID: 212 STATE: WAITING AdminBrokerThread_16 sun.misc.Unsafe.park(Native Method) AdminBrokerThread_16 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) AdminBrokerThread_16 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) AdminBrokerThread_16 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) AdminBrokerThread_16 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) AdminBrokerThread_16 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) AdminBrokerThread_16 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) AdminBrokerThread_16 java.lang.Thread.run(Thread.java:750) AdminBrokerThread_14 TID: 210 STATE: WAITING AdminBrokerThread_14 sun.misc.Unsafe.park(Native Method) AdminBrokerThread_14 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) AdminBrokerThread_14 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) AdminBrokerThread_14 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) AdminBrokerThread_14 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) AdminBrokerThread_14 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) AdminBrokerThread_14 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) AdminBrokerThread_14 java.lang.Thread.run(Thread.java:750) NettyServerCodecThread_5 TID: 195 STATE: TIMED_WAITING NettyServerCodecThread_5 sun.misc.Unsafe.park(Native Method) NettyServerCodecThread_5 java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) NettyServerCodecThread_5 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) NettyServerCodecThread_5 java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467) NettyServerCodecThread_5 io.netty.util.concurrent.SingleThreadEventExecutor.takeTask(SingleThreadEventExecutor.java:256) NettyServerCodecThread_5 io.netty.util.concurrent.DefaultEventExecutor.run(DefaultEventExecutor.java:64) NettyServerCodecThread_5 io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) NettyServerCodecThread_5 io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) NettyServerCodecThread_5 java.lang.Thread.run(Thread.java:750) TimerDequeuePutMessageService TID: 67 STATE: TIMED_WAITING TimerDequeuePutMessageService sun.misc.Unsafe.park(Native Method) TimerDequeuePutMessageService java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) TimerDequeuePutMessageService java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) TimerDequeuePutMessageService java.util.concurrent.LinkedBlockingDeque.pollFirst(LinkedBlockingDeque.java:522) TimerDequeuePutMessageService java.util.concurrent.LinkedBlockingDeque.poll(LinkedBlockingDeque.java:684) TimerDequeuePutMessageService org.apache.rocketmq.store.timer.TimerMessageStore$TimerDequeuePutMessageService.run(TimerMessageStore.java:1474) TimerDequeuePutMessageService java.lang.Thread.run(Thread.java:750) ReadSocketService TID: 216 STATE: RUNNABLE ReadSocketService sun.nio.ch.EPollArrayWrapper.epollWait(Native Method) ReadSocketService sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269) ReadSocketService sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93) ReadSocketService sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86) ReadSocketService sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97) ReadSocketService org.apache.rocketmq.store.ha.DefaultHAConnection$ReadSocketService.run(DefaultHAConnection.java:158) ReadSocketService java.lang.Thread.run(Thread.java:750) ClientManageThread_16 TID: 257 STATE: WAITING ClientManageThread_16 sun.misc.Unsafe.park(Native Method) ClientManageThread_16 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ClientManageThread_16 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ClientManageThread_16 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ClientManageThread_16 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ClientManageThread_16 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ClientManageThread_16 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ClientManageThread_16 java.lang.Thread.run(Thread.java:750) ClientManageThread_13 TID: 234 STATE: WAITING ClientManageThread_13 sun.misc.Unsafe.park(Native Method) ClientManageThread_13 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ClientManageThread_13 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ClientManageThread_13 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ClientManageThread_13 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ClientManageThread_13 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ClientManageThread_13 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ClientManageThread_13 java.lang.Thread.run(Thread.java:750) PullMessageThread_4 TID: 171 STATE: WAITING PullMessageThread_4 sun.misc.Unsafe.park(Native Method) PullMessageThread_4 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) PullMessageThread_4 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) PullMessageThread_4 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) PullMessageThread_4 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) PullMessageThread_4 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) PullMessageThread_4 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) PullMessageThread_4 java.lang.Thread.run(Thread.java:750) AdminBrokerThread_9 TID: 199 STATE: WAITING AdminBrokerThread_9 sun.misc.Unsafe.park(Native Method) AdminBrokerThread_9 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) AdminBrokerThread_9 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) AdminBrokerThread_9 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) AdminBrokerThread_9 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) AdminBrokerThread_9 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) AdminBrokerThread_9 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) AdminBrokerThread_9 java.lang.Thread.run(Thread.java:750) ServerHouseKeepingService TID: 35 STATE: TIMED_WAITING ServerHouseKeepingService java.lang.Thread.sleep(Native Method) ServerHouseKeepingService io.netty.util.HashedWheelTimer$Worker.waitForNextTick(HashedWheelTimer.java:566) ServerHouseKeepingService io.netty.util.HashedWheelTimer$Worker.run(HashedWheelTimer.java:462) ServerHouseKeepingService java.lang.Thread.run(Thread.java:750) StoreStatsService TID: 52 STATE: TIMED_WAITING StoreStatsService sun.misc.Unsafe.park(Native Method) StoreStatsService java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) StoreStatsService java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037) StoreStatsService java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328) StoreStatsService org.apache.rocketmq.common.CountDownLatch2.await(CountDownLatch2.java:114) StoreStatsService org.apache.rocketmq.common.ServiceThread.waitForRunning(ServiceThread.java:117) StoreStatsService org.apache.rocketmq.store.StoreStatsService.run(StoreStatsService.java:533) StoreStatsService java.lang.Thread.run(Thread.java:750) AsyncAppender-Worker-RocketmqPopSiftingAppenderTID: 25 STATE: WAITING AsyncAppender-Worker-RocketmqPopSiftingAppendersun.misc.Unsafe.park(Native Method) AsyncAppender-Worker-RocketmqPopSiftingAppenderjava.util.concurrent.locks.LockSupport.park(LockSupport.java:175) AsyncAppender-Worker-RocketmqPopSiftingAppenderjava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) AsyncAppender-Worker-RocketmqPopSiftingAppenderjava.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403) AsyncAppender-Worker-RocketmqPopSiftingAppenderorg.apache.rocketmq.logging.ch.qos.logback.core.AsyncAppenderBase$Worker.run(AsyncAppenderBase.java:298) NettyServerNIOSelector_3 TID: 218 STATE: RUNNABLE NettyServerNIOSelector_3 sun.nio.ch.EPollArrayWrapper.epollWait(Native Method) NettyServerNIOSelector_3 sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269) NettyServerNIOSelector_3 sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93) NettyServerNIOSelector_3 sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86) NettyServerNIOSelector_3 sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97) NettyServerNIOSelector_3 sun.nio.ch.SelectorImpl.select(SelectorImpl.java:101) NettyServerNIOSelector_3 io.netty.channel.nio.SelectedSelectionKeySetSelector.select(SelectedSelectionKeySetSelector.java:68) NettyServerNIOSelector_3 io.netty.channel.nio.NioEventLoop.select(NioEventLoop.java:810) NettyServerNIOSelector_3 io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:457) NettyServerNIOSelector_3 io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) NettyServerNIOSelector_3 io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) NettyServerNIOSelector_3 java.lang.Thread.run(Thread.java:750) ScheduleMessageTimerThread_16 TID: 118 STATE: WAITING ScheduleMessageTimerThread_16 sun.misc.Unsafe.park(Native Method) ScheduleMessageTimerThread_16 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ScheduleMessageTimerThread_16 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ScheduleMessageTimerThread_16 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088) ScheduleMessageTimerThread_16 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) ScheduleMessageTimerThread_16 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ScheduleMessageTimerThread_16 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ScheduleMessageTimerThread_16 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ScheduleMessageTimerThread_16 java.lang.Thread.run(Thread.java:750) AsyncAppender-Worker-RocketmqTransactionSiftingAppenderTID: 20 STATE: WAITING AsyncAppender-Worker-RocketmqTransactionSiftingAppendersun.misc.Unsafe.park(Native Method) AsyncAppender-Worker-RocketmqTransactionSiftingAppenderjava.util.concurrent.locks.LockSupport.park(LockSupport.java:175) AsyncAppender-Worker-RocketmqTransactionSiftingAppenderjava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) AsyncAppender-Worker-RocketmqTransactionSiftingAppenderjava.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403) AsyncAppender-Worker-RocketmqTransactionSiftingAppenderorg.apache.rocketmq.logging.ch.qos.logback.core.AsyncAppenderBase$Worker.run(AsyncAppenderBase.java:298) ClientManageThread_24 TID: 265 STATE: WAITING ClientManageThread_24 sun.misc.Unsafe.park(Native Method) ClientManageThread_24 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ClientManageThread_24 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ClientManageThread_24 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ClientManageThread_24 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ClientManageThread_24 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ClientManageThread_24 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ClientManageThread_24 java.lang.Thread.run(Thread.java:750) ColdDataCgCtrService TID: 102 STATE: TIMED_WAITING ColdDataCgCtrService sun.misc.Unsafe.park(Native Method) ColdDataCgCtrService java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) ColdDataCgCtrService java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037) ColdDataCgCtrService java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328) ColdDataCgCtrService org.apache.rocketmq.common.CountDownLatch2.await(CountDownLatch2.java:114) ColdDataCgCtrService org.apache.rocketmq.common.ServiceThread.waitForRunning(ServiceThread.java:117) ColdDataCgCtrService org.apache.rocketmq.broker.coldctr.ColdDataCgCtrService.run(ColdDataCgCtrService.java:83) ColdDataCgCtrService java.lang.Thread.run(Thread.java:750) PopReviveService_6 TID: 89 STATE: TIMED_WAITING PopReviveService_6 sun.misc.Unsafe.park(Native Method) PopReviveService_6 java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) PopReviveService_6 java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037) PopReviveService_6 java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328) PopReviveService_6 org.apache.rocketmq.common.CountDownLatch2.await(CountDownLatch2.java:114) PopReviveService_6 org.apache.rocketmq.common.ServiceThread.waitForRunning(ServiceThread.java:117) PopReviveService_6 org.apache.rocketmq.broker.processor.PopReviveService.run(PopReviveService.java:661) PopReviveService_6 java.lang.Thread.run(Thread.java:750) ColdDataCheckService TID: 50 STATE: TIMED_WAITING ColdDataCheckService sun.misc.Unsafe.park(Native Method) ColdDataCheckService java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) ColdDataCheckService java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037) ColdDataCheckService java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328) ColdDataCheckService org.apache.rocketmq.common.CountDownLatch2.await(CountDownLatch2.java:114) ColdDataCheckService org.apache.rocketmq.common.ServiceThread.waitForRunning(ServiceThread.java:117) ColdDataCheckService org.apache.rocketmq.store.CommitLog$ColdDataCheckService.run(CommitLog.java:2274) ColdDataCheckService java.lang.Thread.run(Thread.java:750) ConsumerManageThread_5 TID: 140 STATE: WAITING ConsumerManageThread_5 sun.misc.Unsafe.park(Native Method) ConsumerManageThread_5 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ConsumerManageThread_5 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ConsumerManageThread_5 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ConsumerManageThread_5 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ConsumerManageThread_5 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ConsumerManageThread_5 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ConsumerManageThread_5 java.lang.Thread.run(Thread.java:750) AsyncAppender-Worker-RocketmqRemotingSiftingAppenderTID: 18 STATE: WAITING AsyncAppender-Worker-RocketmqRemotingSiftingAppendersun.misc.Unsafe.park(Native Method) AsyncAppender-Worker-RocketmqRemotingSiftingAppenderjava.util.concurrent.locks.LockSupport.park(LockSupport.java:175) AsyncAppender-Worker-RocketmqRemotingSiftingAppenderjava.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) AsyncAppender-Worker-RocketmqRemotingSiftingAppenderjava.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403) AsyncAppender-Worker-RocketmqRemotingSiftingAppenderorg.apache.rocketmq.logging.ch.qos.logback.core.AsyncAppenderBase$Worker.run(AsyncAppenderBase.java:298) GroupTransferService TID: 55 STATE: TIMED_WAITING GroupTransferService sun.misc.Unsafe.park(Native Method) GroupTransferService java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) GroupTransferService java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037) GroupTransferService java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328) GroupTransferService org.apache.rocketmq.common.CountDownLatch2.await(CountDownLatch2.java:114) GroupTransferService org.apache.rocketmq.common.ServiceThread.waitForRunning(ServiceThread.java:117) GroupTransferService org.apache.rocketmq.store.ha.GroupTransferService.run(GroupTransferService.java:154) GroupTransferService java.lang.Thread.run(Thread.java:750) FlowMonitor TID: 215 STATE: TIMED_WAITING FlowMonitor sun.misc.Unsafe.park(Native Method) FlowMonitor java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) FlowMonitor java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037) FlowMonitor java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328) FlowMonitor org.apache.rocketmq.common.CountDownLatch2.await(CountDownLatch2.java:114) FlowMonitor org.apache.rocketmq.common.ServiceThread.waitForRunning(ServiceThread.java:117) FlowMonitor org.apache.rocketmq.store.ha.FlowMonitor.run(FlowMonitor.java:37) FlowMonitor java.lang.Thread.run(Thread.java:750) NettyServerCodecThread_7 TID: 202 STATE: TIMED_WAITING NettyServerCodecThread_7 sun.misc.Unsafe.park(Native Method) NettyServerCodecThread_7 java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) NettyServerCodecThread_7 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) NettyServerCodecThread_7 java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467) NettyServerCodecThread_7 io.netty.util.concurrent.SingleThreadEventExecutor.takeTask(SingleThreadEventExecutor.java:256) NettyServerCodecThread_7 io.netty.util.concurrent.DefaultEventExecutor.run(DefaultEventExecutor.java:64) NettyServerCodecThread_7 io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) NettyServerCodecThread_7 io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) NettyServerCodecThread_7 java.lang.Thread.run(Thread.java:750) ScheduleMessageTimerThread_18 TID: 120 STATE: WAITING ScheduleMessageTimerThread_18 sun.misc.Unsafe.park(Native Method) ScheduleMessageTimerThread_18 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ScheduleMessageTimerThread_18 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ScheduleMessageTimerThread_18 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088) ScheduleMessageTimerThread_18 java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) ScheduleMessageTimerThread_18 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ScheduleMessageTimerThread_18 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ScheduleMessageTimerThread_18 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ScheduleMessageTimerThread_18 java.lang.Thread.run(Thread.java:750) PullMessageThread_17 TID: 192 STATE: WAITING PullMessageThread_17 sun.misc.Unsafe.park(Native Method) PullMessageThread_17 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) PullMessageThread_17 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) PullMessageThread_17 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) PullMessageThread_17 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) PullMessageThread_17 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) PullMessageThread_17 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) PullMessageThread_17 java.lang.Thread.run(Thread.java:750) ConsumerManageThread_20 TID: 155 STATE: WAITING ConsumerManageThread_20 sun.misc.Unsafe.unpark(Native Method) ConsumerManageThread_20 java.util.concurrent.locks.LockSupport.unpark(LockSupport.java:141) ConsumerManageThread_20 java.util.concurrent.locks.AbstractQueuedSynchronizer.unparkSuccessor(AbstractQueuedSynchronizer.java:662) ConsumerManageThread_20 java.util.concurrent.locks.AbstractQueuedSynchronizer.release(AbstractQueuedSynchronizer.java:1264) ConsumerManageThread_20 java.util.concurrent.locks.ReentrantLock.unlock(ReentrantLock.java:457) ConsumerManageThread_20 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:449) ConsumerManageThread_20 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ConsumerManageThread_20 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ConsumerManageThread_20 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ConsumerManageThread_20 java.lang.Thread.run(Thread.java:750) ConsumerManageThread_19 TID: 154 STATE: WAITING ConsumerManageThread_19 sun.misc.Unsafe.park(Native Method) ConsumerManageThread_19 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ConsumerManageThread_19 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ConsumerManageThread_19 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ConsumerManageThread_19 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ConsumerManageThread_19 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ConsumerManageThread_19 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ConsumerManageThread_19 java.lang.Thread.run(Thread.java:750) FileWatchService TID: 93 STATE: TIMED_WAITING FileWatchService sun.misc.Unsafe.park(Native Method) FileWatchService java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) FileWatchService java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037) FileWatchService java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328) FileWatchService org.apache.rocketmq.common.CountDownLatch2.await(CountDownLatch2.java:114) FileWatchService org.apache.rocketmq.common.ServiceThread.waitForRunning(ServiceThread.java:117) FileWatchService org.apache.rocketmq.srvutil.FileWatchService.run0(FileWatchService.java:64) FileWatchService org.apache.rocketmq.common.LifecycleAwareServiceThread.run(LifecycleAwareServiceThread.java:33) FileWatchService java.lang.Thread.run(Thread.java:750) NettyServerCodecThread_2 TID: 214 STATE: TIMED_WAITING NettyServerCodecThread_2 sun.misc.Unsafe.park(Native Method) NettyServerCodecThread_2 java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) NettyServerCodecThread_2 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) NettyServerCodecThread_2 java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467) NettyServerCodecThread_2 io.netty.util.concurrent.SingleThreadEventExecutor.takeTask(SingleThreadEventExecutor.java:256) NettyServerCodecThread_2 io.netty.util.concurrent.DefaultEventExecutor.run(DefaultEventExecutor.java:64) NettyServerCodecThread_2 io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) NettyServerCodecThread_2 io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) NettyServerCodecThread_2 java.lang.Thread.run(Thread.java:750) AdminBrokerThread_13 TID: 209 STATE: WAITING AdminBrokerThread_13 sun.misc.Unsafe.park(Native Method) AdminBrokerThread_13 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) AdminBrokerThread_13 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) AdminBrokerThread_13 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) AdminBrokerThread_13 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) AdminBrokerThread_13 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) AdminBrokerThread_13 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) AdminBrokerThread_13 java.lang.Thread.run(Thread.java:750) AdminBrokerThread_11 TID: 205 STATE: WAITING AdminBrokerThread_11 sun.misc.Unsafe.park(Native Method) AdminBrokerThread_11 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) AdminBrokerThread_11 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) AdminBrokerThread_11 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) AdminBrokerThread_11 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) AdminBrokerThread_11 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) AdminBrokerThread_11 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) AdminBrokerThread_11 java.lang.Thread.run(Thread.java:750) AllocateMappedFileService TID: 44 STATE: WAITING AllocateMappedFileService sun.misc.Unsafe.park(Native Method) AllocateMappedFileService java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) AllocateMappedFileService java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) AllocateMappedFileService java.util.concurrent.PriorityBlockingQueue.take(PriorityBlockingQueue.java:549) AllocateMappedFileService org.apache.rocketmq.store.AllocateMappedFileService.mmapOperation(AllocateMappedFileService.java:157) AllocateMappedFileService org.apache.rocketmq.store.AllocateMappedFileService.run(AllocateMappedFileService.java:144) AllocateMappedFileService java.lang.Thread.run(Thread.java:750) ClientManageThread_29 TID: 270 STATE: WAITING ClientManageThread_29 sun.misc.Unsafe.park(Native Method) ClientManageThread_29 java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) ClientManageThread_29 java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) ClientManageThread_29 java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) ClientManageThread_29 java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) ClientManageThread_29 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) ClientManageThread_29 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ClientManageThread_29 java.lang.Thread.run(Thread.java:750)