kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Boyang Chen (JIRA)" <j...@apache.org>
Subject [jira] [Created] (KAFKA-8620) Fix potential race condition in StreamThread state change
Date Mon, 01 Jul 2019 22:18:00 GMT
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)

Mime
View raw message