[ https://issues.apache.org/jira/browse/KAFKA-5787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Guozhang Wang updated KAFKA-5787: --------------------------------- Fix Version/s: 1.0.0 > 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 > Fix For: 0.11.0.1, 1.0.0 > > > 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)