[jira] [Created] (FLINK-5738) Destroy created backend when task is canceled

[Shang Yuanchun (Jira)]

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)