[
https://issues.apache.org/jira/browse/KAFKA-8620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16882623#comment-16882623
]
ASF GitHub Bot commented on KAFKA-8620:
---------------------------------------
ijuma 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
> 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.3#76005)
