[
https://issues.apache.org/jira/browse/KAFKA-9178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16972987#comment-16972987
]
ASF GitHub Bot commented on KAFKA-9178:
---------------------------------------
ableegoldman commented on pull request #7686: KAFKA-9178: restoredPartitions is
not cleared until the last restoring task completes
URL: https://github.com/apache/kafka/pull/7686
The ideal fix for this PR is blocked by
https://issues.apache.org/jira/browse/KAFKA-9177, since any partitions we
remove from `restoredPartitions` will just be added back to the set on the next
loop unless we remove/pause completed partitions in the restore consumer
For now, we can just remove from `restoredPartitions` whenever we suspend or
close a running task.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
> restoredPartitions is not cleared until the last restoring task completes
> -------------------------------------------------------------------------
>
> Key: KAFKA-9178
> URL: https://issues.apache.org/jira/browse/KAFKA-9178
> Project: Kafka
> Issue Type: Bug
> Reporter: Boyang Chen
> Assignee: Boyang Chen
> Priority: Blocker
> Labels: streams
> Fix For: 2.4.0
>
>
> We check the `active` set is empty during clostLostTasks(). However one thing
> we miss is to remove the changelog topics from restored partitions as well.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
