[
https://issues.apache.org/jira/browse/KAFKA-17354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874287#comment-17874287
]
Anton Liauchuk commented on KAFKA-17354:
----------------------------------------
I am interested in working on this task. [~aoli-al] could you please assign
this task to me?
> 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
> Reporter: Ao Li
> 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)
