Xiaogang Shi created FLINK-5738:
-----------------------------------
Summary: Destroy created backend when task is canceled
Key: FLINK-5738
URL: https://issues.apache.org/jira/browse/FLINK-5738
Project: Flink
Issue Type: Bug
Components: State Backends, Checkpointing
Affects Versions: 1.2.0
Reporter: Xiaogang Shi
When a task is canceled, the {{ClosableRegistry}} will be closed in the cancel
thread. However, the task may still in the creation of {{KeyedStateBackend}},
and it will fail to register the backend to the {{ClosableRegistry}}. Because
the backend is not assigned to the operator yet (due to the exception), the
backend will not be destroyed when the task thread exits.
A simple solution is to catch exception in the registering and destroy the
created backend in the case of failures.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
