[
https://issues.apache.org/jira/browse/KAFKA-10097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-10097.
---------------------------------
Resolution: Fixed
> Avoid passing task checkpoint file externally
> ---------------------------------------------
>
> Key: KAFKA-10097
> URL: https://issues.apache.org/jira/browse/KAFKA-10097
> Project: Kafka
> Issue Type: Improvement
> Components: streams
> Reporter: Boyang Chen
> Assignee: Boyang Chen
> Priority: Major
>
> In StreamTask, we have the logic to generate a checkpoint offset map to be
> materialized through StateManager#checkpoint. This map could be either empty
> map or null, which the former case indicates to only pull down existing state
> store checkpoint data, while the latter indicates no need to do a checkpoint
> in the case such as we are suspending a task.
> Having two similar special logics for checkpointing could lead to unexpected
> bugs, also we should think about separating the empty checkpoint case vs
> passed-in checkpoint case.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
