[
https://issues.apache.org/jira/browse/KAFKA-10097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17126001#comment-17126001
]
Boyang Chen commented on KAFKA-10097:
-------------------------------------
[~feyman] Thank you for the interest! Unfortunately this ticket is still under
discussion, will let you know the result. Meanwhile I will look for other side
improvements for Streams to get you started :)
> Avoid getting null map for task checkpoint
> ------------------------------------------
>
> Key: KAFKA-10097
> URL: https://issues.apache.org/jira/browse/KAFKA-10097
> Project: Kafka
> Issue Type: Improvement
> Components: streams
> Reporter: 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)
