[ https://issues.apache.org/jira/browse/KAFKA-5787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16142879#comment-16142879 ]
ASF GitHub Bot commented on KAFKA-5787: --------------------------------------- Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3736 > StoreChangeLogReader needs to restore partitions that were added post > initialization > ------------------------------------------------------------------------------------ > > Key: KAFKA-5787 > URL: https://issues.apache.org/jira/browse/KAFKA-5787 > Project: Kafka > Issue Type: Bug > Components: streams > Affects Versions: 0.11.0.1, 1.0.0 > Reporter: Damian Guy > Assignee: Damian Guy > Priority: Blocker > > Investigation of {{KStreamRepartitionJoinTest}} failures uncovered this bug. > If a task fails during initialization due to a {{LockException}}, its > changelog partitions are not immediately added to the > {{StoreChangelogReader}} as the thread doesn't hold the lock. However > {{StoreChangelogReader#restore}} will be called and it sets the initialized > flag. On a subsequent successfull call to initialize the new tasks the > partitions are added to the {{StoreChangelogReader}}, however as it is > already initialized these new partitions will never be restored. So the task > will remain in a non-running state forever -- This message was sent by Atlassian JIRA (v6.4.14#64029)