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)