[jira] [Commented] (KAFKA-10362) When resuming Streams active task with EOS, the checkpoint file should be deleted

["Sharath Bhat (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/KAFKA-10362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17189629#comment-17189629 ] 

Sharath Bhat commented on KAFKA-10362:
--------------------------------------

Hi [~guozhang], 

I worked on the bug and have raised a [PR|https://github.com/apache/kafka/pull/9247]

could you please review the PR.

and can I get this ticket on my name?

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