[jira] [Created] (FLINK-18983) Job doesn't changed to failed if close function has blocked

[Shang Yuanchun (Jira)]

YufeiLiu created FLINK-18983:
--------------------------------

             Summary: Job doesn't changed to failed if close function has blocked
                 Key: FLINK-18983
                 URL: https://issues.apache.org/jira/browse/FLINK-18983
             Project: Flink
          Issue Type: Bug
          Components: Runtime / Task
    Affects Versions: 1.11.0
            Reporter: YufeiLiu


If a operator throw a exception, it will break process loop and dispose all operator. But state will never switch to FAILED if block in Function.close, and JobMaster can't know the final state and do restart.

Task have {{TaskCancelerWatchDog}} to kill process if cancellation timeout, but it doesn't work for FAILED task.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)