Boyang Chen created KAFKA-8620:
----------------------------------
Summary: Fix potential race condition in StreamThread state change
Key: KAFKA-8620
URL: https://issues.apache.org/jira/browse/KAFKA-8620
Project: Kafka
Issue Type: Bug
Reporter: Boyang Chen
Assignee: Boyang Chen
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)
