[
https://issues.apache.org/jira/browse/KAFKA-10362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17181231#comment-17181231
]
Ilia Pasynkov commented on KAFKA-10362:
---------------------------------------
Hello, can I pick this task?
> When resuming Streams active task with EOS, the checkpoint file should be
> deleted
> ---------------------------------------------------------------------------------
>
> Key: KAFKA-10362
> URL: https://issues.apache.org/jira/browse/KAFKA-10362
> Project: Kafka
> Issue Type: Bug
> Components: streams
> Affects Versions: 2.6.0
> Reporter: Guozhang Wang
> Priority: Major
> Labels: newbie++
>
> Today when we suspend a task we commit and along with the commit we always
> write checkpoint file even if we are eosEnabled (since the state is already
> SUSPENDED). But the suspended task may later be resumed and in that case the
> checkpoint file should be deleted since it should only be written when it is
> cleanly closed.
> With our latest rebalance protocol in KIP-429, resume would not be called
> since all suspended tasks would be closed, but with the old eager protocol it
> may still be called — I think that may be the reason we did not get it often.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)