Chia-Ping Tsai created KAFKA-17907: -------------------------------------- Summary: PersisterStateManagerTest hangs Key: KAFKA-17907 URL: https://issues.apache.org/jira/browse/KAFKA-17907 Project: Kafka Issue Type: Improvement Reporter: Chia-Ping Tsai Assignee: Chia-Ping Tsai
see https://github.com/apache/kafka/actions/runs/11604040184/artifacts/2126548822 2024-10-31 03:47:00 Full thread dump OpenJDK 64-Bit Server VM (11.0.24+8 mixed mode): Threads class SMR info: _java_thread_list=0x00007f68880065d0, length=16, elements={ 0x00007f68e8027800, 0x00007f68e80a6800, 0x00007f68e80aa800, 0x00007f68e80c2800, 0x00007f68e80c4800, 0x00007f68e80c6800, 0x00007f68e80c8800, 0x00007f68e80ca800, 0x00007f68e815a800, 0x00007f68e8624000, 0x00007f68e8643000, 0x00007f68e8646800, 0x00007f68b0001000, 0x00007f68e8a33800, 0x00007f68e8a36000, 0x00007f6868001000 } "Test worker" #1 prio=5 os_prio=0 cpu=2207.23ms elapsed=10376.18s tid=0x00007f68e8027800 nid=0x11d6 waiting on condition [0x00007f68ee9fa000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.24/Native Method) - parking to wait for <0x000000008076c728> (a java.util.concurrent.CompletableFuture$Signaller) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.24/LockSupport.java:194) at java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.24/CompletableFuture.java:1796) at java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.24/ForkJoinPool.java:3128) at java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.24/CompletableFuture.java:1830) at java.util.concurrent.CompletableFuture.get(java.base@11.0.24/CompletableFuture.java:2004) at org.apache.kafka.server.share.persister.PersisterStateManagerTest.testReadStateRequestFailButCoordinatorFoundSuccessfully(PersisterStateManagerTest.java:1582) at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(java.base@11.0.24/Native Method) at jdk.internal.reflect.NativeMethodAccessorImpl.invoke(java.base@11.0.24/NativeMethodAccessorImpl.java:62) at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(java.base@11.0.24/DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(java.base@11.0.24/Method.java:566) at org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:728) at org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60) at org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131) at org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:156) at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:147) at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestMethod(TimeoutExtension.java:86) at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor$$Lambda$198/0x00000001001bd840.apply(Unknown Source) at org.junit.jupiter.engine.execution.InterceptingExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(InterceptingExecutableInvoker.java:103) at org.junit.jupiter.engine.execution.InterceptingExecutableInvoker$ReflectiveInterceptorCall$$Lambda$199/0x00000001001bdc40.apply(Unknown Source) at org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.lambda$invoke$0(InterceptingExecutableInvoker.java:93) at org.junit.jupiter.engine.execution.InterceptingExecutableInvoker$$Lambda$385/0x0000000100208440.apply(Unknown Source) at org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106) at org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64) at org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45) at org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37) at org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:92) at org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:86) at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$7(TestMethodTestDescriptor.java:218) at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor$$Lambda$445/0x0000000100367840.execute(Unknown Source) at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73) at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:214) at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:139) at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:69) at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151) at org.junit.platform.engine.support.hierarchical.NodeTestTask$$Lambda$305/0x00000001001ea840.execute(Unknown Source) at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73) at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141) at org.junit.platform.engine.support.hierarchical.NodeTestTask$$Lambda$304/0x00000001001ea440.invoke(Unknown Source) at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137) at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139) at org.junit.platform.engine.support.hierarchical.NodeTestTask$$Lambda$303/0x00000001001ea040.execute(Unknown Source) at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73) at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138) at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95) at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService$$Lambda$309/0x00000001001eb840.accept(Unknown Source) at java.util.ArrayList.forEach(java.base@11.0.24/ArrayList.java:1541) at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41) at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155) at org.junit.platform.engine.support.hierarchical.NodeTestTask$$Lambda$305/0x00000001001ea840.execute(Unknown Source) at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73) at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141) at org.junit.platform.engine.support.hierarchical.NodeTestTask$$Lambda$304/0x00000001001ea440.invoke(Unknown Source) at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137) at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139) at org.junit.platform.engine.support.hierarchical.NodeTestTask$$Lambda$303/0x00000001001ea040.execute(Unknown Source) at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73) at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138) at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95) at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService$$Lambda$309/0x00000001001eb840.accept(Unknown Source) at java.util.ArrayList.forEach(java.base@11.0.24/ArrayList.java:1541) at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41) at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155) at org.junit.platform.engine.support.hierarchical.NodeTestTask$$Lambda$305/0x00000001001ea840.execute(Unknown Source) at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73) at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141) at org.junit.platform.engine.support.hierarchical.NodeTestTask$$Lambda$304/0x00000001001ea440.invoke(Unknown Source) at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137) at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139) at org.junit.platform.engine.support.hierarchical.NodeTestTask$$Lambda$303/0x00000001001ea040.execute(Unknown Source) at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73) at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138) at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95) at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:35) at org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57) at org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:54) at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:198) at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:169) at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:93) at org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:58) at org.junit.platform.launcher.core.EngineExecutionOrchestrator$$Lambda$258/0x00000001001cd440.accept(Unknown Source) at org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:141) at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:57) at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:103) at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:85) at org.junit.platform.launcher.core.DelegatingLauncher.execute(DelegatingLauncher.java:47) at org.gradle.api.internal.tasks.testing.junitplatform.JUnitPlatformTestClassProcessor$CollectAllTestClassesExecutor.processAllTestClasses(JUnitPlatformTestClassProcessor.java:124) at org.gradle.api.internal.tasks.testing.junitplatform.JUnitPlatformTestClassProcessor$CollectAllTestClassesExecutor.access$000(JUnitPlatformTestClassProcessor.java:99) at org.gradle.api.internal.tasks.testing.junitplatform.JUnitPlatformTestClassProcessor.stop(JUnitPlatformTestClassProcessor.java:94) at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.stop(SuiteTestClassProcessor.java:63) at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(java.base@11.0.24/Native Method) at jdk.internal.reflect.NativeMethodAccessorImpl.invoke(java.base@11.0.24/NativeMethodAccessorImpl.java:62) at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(java.base@11.0.24/DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(java.base@11.0.24/Method.java:566) at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:36) at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24) at org.gradle.internal.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:33) at org.gradle.internal.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:92) at com.sun.proxy.$Proxy4.stop(Unknown Source) at org.gradle.api.internal.tasks.testing.worker.TestWorker$3.run(TestWorker.java:200) at org.gradle.api.internal.tasks.testing.worker.TestWorker.executeAndMaintainThreadName(TestWorker.java:132) at org.gradle.api.internal.tasks.testing.worker.TestWorker.execute(TestWorker.java:103) at org.gradle.api.internal.tasks.testing.worker.TestWorker.execute(TestWorker.java:63) at org.gradle.process.internal.worker.child.ActionExecutionWorker.execute(ActionExecutionWorker.java:56) at org.gradle.process.internal.worker.child.SystemApplicationClassLoaderWorker.call(SystemApplicationClassLoaderWorker.java:121) at org.gradle.process.internal.worker.child.SystemApplicationClassLoaderWorker.call(SystemApplicationClassLoaderWorker.java:71) at worker.org.gradle.process.internal.worker.GradleWorkerMain.run(GradleWorkerMain.java:69) at worker.org.gradle.process.internal.worker.GradleWorkerMain.main(GradleWorkerMain.java:74) "Reference Handler" #2 daemon prio=10 os_prio=0 cpu=1.59ms elapsed=10376.12s tid=0x00007f68e80a6800 nid=0x11d9 waiting on condition [0x00007f68c7bfa000] java.lang.Thread.State: RUNNABLE at java.lang.ref.Reference.waitForReferencePendingList(java.base@11.0.24/Native Method) at java.lang.ref.Reference.processPendingReferences(java.base@11.0.24/Reference.java:241) at java.lang.ref.Reference$ReferenceHandler.run(java.base@11.0.24/Reference.java:213) "Finalizer" #3 daemon prio=8 os_prio=0 cpu=0.23ms elapsed=10376.10s tid=0x00007f68e80aa800 nid=0x11da in Object.wait() [0x00007f68c77fa000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.24/Native Method) - waiting on <0x00000000803bba90> (a java.lang.ref.ReferenceQueue$Lock) at java.lang.ref.ReferenceQueue.remove(java.base@11.0.24/ReferenceQueue.java:155) - waiting to re-lock in wait() <0x00000000803bba90> (a java.lang.ref.ReferenceQueue$Lock) at java.lang.ref.ReferenceQueue.remove(java.base@11.0.24/ReferenceQueue.java:176) at java.lang.ref.Finalizer$FinalizerThread.run(java.base@11.0.24/Finalizer.java:170) "Signal Dispatcher" #4 daemon prio=9 os_prio=0 cpu=0.51ms elapsed=10376.08s tid=0x00007f68e80c2800 nid=0x11db runnable [0x0000000000000000] java.lang.Thread.State: RUNNABLE "Service Thread" #5 daemon prio=9 os_prio=0 cpu=0.13ms elapsed=10376.08s tid=0x00007f68e80c4800 nid=0x11dc runnable [0x0000000000000000] java.lang.Thread.State: RUNNABLE "C2 CompilerThread0" #6 daemon prio=9 os_prio=0 cpu=2205.02ms elapsed=10376.07s tid=0x00007f68e80c6800 nid=0x11dd waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE No compile task "C1 CompilerThread0" #8 daemon prio=9 os_prio=0 cpu=1254.31ms elapsed=10376.06s tid=0x00007f68e80c8800 nid=0x11de waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE No compile task "Sweeper thread" #9 daemon prio=9 os_prio=0 cpu=2.87ms elapsed=10376.04s tid=0x00007f68e80ca800 nid=0x11df runnable [0x0000000000000000] java.lang.Thread.State: RUNNABLE "Common-Cleaner" #10 daemon prio=8 os_prio=0 cpu=7.03ms elapsed=10375.93s tid=0x00007f68e815a800 nid=0x11e1 in Object.wait() [0x00007f68c61fd000] java.lang.Thread.State: TIMED_WAITING (on object monitor) at java.lang.Object.wait(java.base@11.0.24/Native Method) - waiting on <0x000000008015b628> (a java.lang.ref.ReferenceQueue$Lock) at java.lang.ref.ReferenceQueue.remove(java.base@11.0.24/ReferenceQueue.java:155) - waiting to re-lock in wait() <0x000000008015b628> (a java.lang.ref.ReferenceQueue$Lock) at jdk.internal.ref.CleanerImpl.run(java.base@11.0.24/CleanerImpl.java:148) at java.lang.Thread.run(java.base@11.0.24/Thread.java:829) at jdk.internal.misc.InnocuousThread.run(java.base@11.0.24/InnocuousThread.java:161) "/127.0.0.1:45028 to /127.0.0.1:34841 workers" #12 prio=5 os_prio=0 cpu=2.44ms elapsed=10374.51s tid=0x00007f68e8624000 nid=0x11ef waiting on condition [0x00007f68c4dfe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.24/Native Method) - parking to wait for <0x0000000080124650> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.24/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.24/AbstractQueuedSynchronizer.java:2081) at org.gradle.internal.remote.internal.hub.queue.EndPointQueue.take(EndPointQueue.java:49) at org.gradle.internal.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:403) at org.gradle.internal.concurrent.ExecutorPolicy$CatchAndRecordFailures.onExecute(ExecutorPolicy.java:64) at org.gradle.internal.concurrent.AbstractManagedExecutor$1.run(AbstractManagedExecutor.java:48) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.24/ThreadPoolExecutor.java:1128) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.24/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.24/Thread.java:829) "/127.0.0.1:45028 to /127.0.0.1:34841 workers Thread 2" #13 prio=5 os_prio=0 cpu=3.66ms elapsed=10374.45s tid=0x00007f68e8643000 nid=0x11f0 waiting on condition [0x00007f68c49fe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.24/Native Method) - parking to wait for <0x0000000080161b40> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.24/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.24/AbstractQueuedSynchronizer.java:2081) at org.gradle.internal.remote.internal.hub.queue.EndPointQueue.take(EndPointQueue.java:49) at org.gradle.internal.remote.internal.hub.MessageHub$ConnectionDispatch.run(MessageHub.java:322) at org.gradle.internal.concurrent.ExecutorPolicy$CatchAndRecordFailures.onExecute(ExecutorPolicy.java:64) at org.gradle.internal.concurrent.AbstractManagedExecutor$1.run(AbstractManagedExecutor.java:48) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.24/ThreadPoolExecutor.java:1128) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.24/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.24/Thread.java:829) "/127.0.0.1:45028 to /127.0.0.1:34841 workers Thread 3" #14 prio=5 os_prio=0 cpu=8.40ms elapsed=10374.44s tid=0x00007f68e8646800 nid=0x11f1 runnable [0x00007f68c45fe000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPoll.wait(java.base@11.0.24/Native Method) at sun.nio.ch.EPollSelectorImpl.doSelect(java.base@11.0.24/EPollSelectorImpl.java:120) at sun.nio.ch.SelectorImpl.lockAndDoSelect(java.base@11.0.24/SelectorImpl.java:124) - locked <0x000000008011e500> (a sun.nio.ch.Util$2) - locked <0x000000008011e2c0> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(java.base@11.0.24/SelectorImpl.java:141) at org.gradle.internal.remote.internal.inet.SocketConnection$SocketInputStream.read(SocketConnection.java:190) at com.esotericsoftware.kryo.io.Input.fill(Input.java:146) at com.esotericsoftware.kryo.io.Input.require(Input.java:178) at com.esotericsoftware.kryo.io.Input.readByte(Input.java:295) at org.gradle.internal.serialize.kryo.KryoBackedDecoder.readByte(KryoBackedDecoder.java:88) at org.gradle.internal.remote.internal.hub.InterHubMessageSerializer$MessageReader.read(InterHubMessageSerializer.java:64) at org.gradle.internal.remote.internal.hub.InterHubMessageSerializer$MessageReader.read(InterHubMessageSerializer.java:52) at org.gradle.internal.remote.internal.inet.SocketConnection.receive(SocketConnection.java:86) at org.gradle.internal.remote.internal.hub.MessageHub$ConnectionReceive.run(MessageHub.java:270) at org.gradle.internal.concurrent.ExecutorPolicy$CatchAndRecordFailures.onExecute(ExecutorPolicy.java:64) at org.gradle.internal.concurrent.AbstractManagedExecutor$1.run(AbstractManagedExecutor.java:48) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.24/ThreadPoolExecutor.java:1128) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.24/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.24/Thread.java:829) "Attach Listener" #16 daemon prio=9 os_prio=0 cpu=2.08ms elapsed=10372.12s tid=0x00007f68b0001000 nid=0x1221 waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE "persisterStateManagerTestTimer" #23 prio=5 os_prio=0 cpu=1081.01ms elapsed=10365.18s tid=0x00007f68e8a33800 nid=0x1253 waiting on condition [0x00007f688da51000] java.lang.Thread.State: TIMED_WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.24/Native Method) - parking to wait for <0x000000008062dfa0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.24/LockSupport.java:234) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.24/AbstractQueuedSynchronizer.java:2123) at java.util.concurrent.DelayQueue.poll(java.base@11.0.24/DelayQueue.java:265) at org.apache.kafka.server.util.timer.SystemTimer.advanceClock(SystemTimer.java:90) at org.apache.kafka.server.util.timer.SystemTimerReaper$Reaper.doWork(SystemTimerReaper.java:36) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:136) "PersisterStateManager" #24 prio=5 os_prio=0 cpu=9400705.39ms elapsed=10365.16s tid=0x00007f68e8a36000 nid=0x1254 runnable [0x00007f688d650000] java.lang.Thread.State: RUNNABLE at java.util.concurrent.ConcurrentLinkedDeque.peekFirst(java.base@11.0.24/ConcurrentLinkedDeque.java:875) at java.util.concurrent.ConcurrentLinkedDeque.peek(java.base@11.0.24/ConcurrentLinkedDeque.java:995) at org.apache.kafka.clients.MockClient.checkTimeoutOfPendingRequests(MockClient.java:347) at org.apache.kafka.clients.MockClient.poll(MockClient.java:320) at org.apache.kafka.server.util.InterBrokerSendThread.pollOnce(InterBrokerSendThread.java:110) at org.apache.kafka.server.util.InterBrokerSendThread.doWork(InterBrokerSendThread.java:137) at org.apache.kafka.server.util.ShutdownableThread.run(ShutdownableThread.java:136) "executor-persisterStateManagerTestTimer" #25 prio=5 os_prio=0 cpu=0.16ms elapsed=10364.93s tid=0x00007f6868001000 nid=0x125b waiting on condition [0x00007f688effe000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park(java.base@11.0.24/Native Method) - parking to wait for <0x000000008062ddf8> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(java.base@11.0.24/LockSupport.java:194) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.24/AbstractQueuedSynchronizer.java:2081) at java.util.concurrent.LinkedBlockingQueue.take(java.base@11.0.24/LinkedBlockingQueue.java:433) at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.24/ThreadPoolExecutor.java:1054) at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.24/ThreadPoolExecutor.java:1114) at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.24/ThreadPoolExecutor.java:628) at java.lang.Thread.run(java.base@11.0.24/Thread.java:829) "VM Thread" os_prio=0 cpu=35454.66ms elapsed=10376.13s tid=0x00007f68e809e800 nid=0x11d8 runnable "ParGC Thread#0" os_prio=0 cpu=35694.39ms elapsed=10376.18s tid=0x00007f68e8040800 nid=0x11d7 runnable "ParGC Thread#1" os_prio=0 cpu=35758.01ms elapsed=10371.35s tid=0x00007f68c0005000 nid=0x1226 runnable "ParGC Thread#2" os_prio=0 cpu=35463.10ms elapsed=10371.33s tid=0x00007f68c0006800 nid=0x1227 runnable "ParGC Thread#3" os_prio=0 cpu=35461.60ms elapsed=10371.32s tid=0x00007f68c0008000 nid=0x1228 runnable "VM Periodic Task Thread" os_prio=0 cpu=3409.44ms elapsed=10375.95s tid=0x00007f68e814b800 nid=0x11e0 waiting on condition JNI global refs: 15, weak refs: 0 -- This message was sent by Atlassian Jira (v8.20.10#820010)