Boyang Chen created KAFKA-10097:
-----------------------------------
Summary: Avoid getting null map for task checkpoint
Key: KAFKA-10097
URL: https://issues.apache.org/jira/browse/KAFKA-10097
Project: Kafka
Issue Type: Improvement
Reporter: Boyang Chen
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)
