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)
