[jira] [Assigned] (KAFKA-10532) Do not wipe state store under EOS when closing-dirty a RESTORING active or RUNNING standby task

["Shay Lin (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/KAFKA-10532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Shay Lin reassigned KAFKA-10532:
--------------------------------

    Assignee: Shay Lin

> Do not wipe state store under EOS when closing-dirty a RESTORING active or RUNNING standby task
> -----------------------------------------------------------------------------------------------
>
>                 Key: KAFKA-10532
>                 URL: https://issues.apache.org/jira/browse/KAFKA-10532
>             Project: Kafka
>          Issue Type: Improvement
>          Components: streams
>            Reporter: Guozhang Wang
>            Assignee: Shay Lin
>            Priority: Major
>              Labels: new-streams-runtime-should-fix, newbie++
>
> Today whenever we are closing-dirty a task, we always wipe out the state stores if we are under EOS. But when the closing task was a RESTORING active, or a RUNNING standby, we may actually not need to wipe out the stores since we know that upon resuming, we would still continue restoring the task before transit to processing ever (assuming the LEO offset would not be truncated), i.e. when they resumes it does not matter if the same records gets applied twice during the continued restoration.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)