mumrah commented on PR #17191: URL: https://github.com/apache/kafka/pull/17191#issuecomment-2350765766
Thread dump here https://github.com/apache/kafka/actions/runs/10852637802/artifacts/1932150615 ``` clientId-StreamThread-1-TaskExecutor-1" #12570 prio=5 os_prio=0 cpu=0.21ms elapsed=7481.03s tid=0x00007f4eea2ec410 nid=0x197ee waiting on condition [0x00007f4ab53fb000] java.lang.Thread.State: WAITING (parking) at jdk.internal.misc.Unsafe.park([email protected]/Native Method) - parking to wait for <0x00000000d60d47d0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park([email protected]/LockSupport.java:341) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionNode.block([email protected]/AbstractQueuedSynchronizer.java:506) at java.util.concurrent.ForkJoinPool.unmanagedBlock([email protected]/ForkJoinPool.java:3465) at java.util.concurrent.ForkJoinPool.managedBlock([email protected]/ForkJoinPool.java:3436) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@17".0.12/AbstractQueuedSynchronizer.java:1625) at org.apache.kafka.streams.processor.internals.tasks.DefaultTaskManager.lambda$awaitProcessableTasks$1(DefaultTaskManager.java:142) at org.apache.kafka.streams.processor.internals.tasks.DefaultTaskManager$$Lambda$3587/0x00007f4e888ed980.get(Unknown Source) at org.apache.kafka.streams.processor.internals.tasks.DefaultTaskManager.returnWithTasksLocked(DefaultTaskManager.java:353) at org.apache.kafka.streams.processor.internals.tasks.DefaultTaskManager.awaitProcessableTasks(DefaultTaskManager.java:129) at org.apache.kafka.streams.processor.internals.tasks.DefaultTaskExecutor$TaskExecutorThread.runOnce(DefaultTaskExecutor.java:119) at org.apache.kafka.streams.processor.internals.tasks.DefaultTaskExecutor$TaskExecutorThread.run(DefaultTaskExecutor.java:62) ``` ``` "stream-thread-test-87bf53a8-54f2-485f-a4b6-acdbec0a8b3d-StreamThread-1" #1 prio=5 os_prio=0 cpu=39817.70ms elapsed=10386.12s tid=0x00007f4ee802c700 nid=0x1186 in Object.wait() [0x00007f4eecf13000] java.lang.Thread.State: TIMED_WAITING (on object monitor) at java.lang.Object.wait([email protected]/Native Method) - waiting on <no object reference available> at java.lang.Thread.join([email protected]/Thread.java:1307) - locked <0x00000000d60d4bc0> (a org.apache.kafka.streams.processor.internals.tasks.DefaultTaskExecutor$TaskExecutorThread) at org.apache.kafka.streams.processor.internals.tasks.DefaultTaskExecutor.awaitShutdown(DefaultTaskExecutor.java:264) at org.apache.kafka.streams.processor.internals.tasks.DefaultTaskManager.shutdown(DefaultTaskManager.java:377) at org.apache.kafka.streams.processor.internals.TaskManager.shutdownSchedulingTaskManager(TaskManager.java:1512) at org.apache.kafka.streams.processor.internals.TaskManager.shutdown(TaskManager.java:1444) at org.apache.kafka.streams.processor.internals.StreamThreadTest.tearDown(StreamThreadTest.java:233) ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
