Zakelly Lan created FLINK-35784:
-----------------------------------
Summary: The cp file-merging directory not properly registered in
SharedStateRegistry
Key: FLINK-35784
URL: https://issues.apache.org/jira/browse/FLINK-35784
Project: Flink
Issue Type: Bug
Components: Runtime / Checkpointing
Affects Versions: 1.20.0
Reporter: Zakelly Lan
Assignee: Zakelly Lan
The {{OperatorSubtaskState}} only make keyed state to register with
{{SharedStateRegistry}}. However, the file-merging directories's handle are
wrapped in {{FileMergingOperatorStreamStateHandle}}, which is an
{{OperatorStreamStateHandle}}. That means the {{#registerSharedStates}} is
never called, so the registry will never delete the directories.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
