[
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)
