[
https://issues.apache.org/jira/browse/KAFKA-8620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16885655#comment-16885655
]
ASF GitHub Bot commented on KAFKA-8620:
---------------------------------------
mjsax commented on pull request #7021: KAFKA-8620: fix NPE due to race
condition during shutdown while rebalancing
URL: https://github.com/apache/kafka/pull/7021
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
> Race condition in StreamThread state change
> -------------------------------------------
>
> Key: KAFKA-8620
> URL: https://issues.apache.org/jira/browse/KAFKA-8620
> Project: Kafka
> Issue Type: Bug
> Components: streams
> Affects Versions: 2.1.0
> Reporter: Boyang Chen
> Assignee: Boyang Chen
> Priority: Major
>
> In the call to `StreamThread.addRecordsToTasks` we don't have synchronization
> when we attempt to extract active tasks. If after one long poll in runOnce
> the application state changes to PENDING_SHUTDOWN, there is a potential close
> on TaskManager which erases the active tasks map, thus triggering NPE and
> bringing the thread state to a false shutdown.
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
