[jira] [Created] (FLINK-32658) State should not be silently removed when ignore-unclaimed-state is false

["Rui Fan (Jira)" <ji...@apache.org>]

Rui Fan created FLINK-32658:
-------------------------------

             Summary: State should not be silently removed when ignore-unclaimed-state is false
                 Key: FLINK-32658
                 URL: https://issues.apache.org/jira/browse/FLINK-32658
             Project: Flink
          Issue Type: Bug
          Components: Runtime / Checkpointing
    Affects Versions: 1.17.1, 1.18.0
            Reporter: Rui Fan
            Assignee: Rui Fan


When ignore-unclaimed-state is false and the old state is removed, flink should throw exception.

It's similar with removing an stateful operator.

This case occurs not only when the user removes state, but also when the operator is replaced. 

For example: upgrade FlinkKafkaConsumer to KafkaSource. All logical are not changed, so the operator id isn't changed. The KafkaSource cannot resume from the state of FlinkKafkaConsumer. However, flink job can start, and the state is silently discarded.




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