[
https://issues.apache.org/jira/browse/KAFKA-17354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17939336#comment-17939336
]
Matthias J. Sax commented on KAFKA-17354:
-----------------------------------------
I am wondering if [https://github.com/apache/kafka/pull/18765] might have fixe
this one?
> StreamThread::setState race condition causes java.lang.RuntimeException:
> State mismatch PENDING_SHUTDOWN different from STARTING
> --------------------------------------------------------------------------------------------------------------------------------
>
> Key: KAFKA-17354
> URL: https://issues.apache.org/jira/browse/KAFKA-17354
> Project: Kafka
> Issue Type: Bug
> Components: streams
> Reporter: Ao Li
> Assignee: Anton Liauchuk
> Priority: Major
>
> I saw a test failure in `StreamThreadTest::shouldChangeStateAtStartClose`. A
> race condition in `setState` causes an uncaught exception thrown in
> `StateListenerStub`.
> Basically, the function `setState` allows two threads to call
> `stateListener.onChange` concurrently.
> This patch will help you to reproduce the failure deterministically.
> https://github.com/aoli-al/kafka/commit/033a9a33766740e6843effb9beabfdcb3804846b
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
