John Lonergan created FLINK-13588:

             Summary: StreamTask.handleAsyncException throws away the exception 
                 Key: FLINK-13588
             Project: Flink
          Issue Type: Bug
    Affects Versions: 1.8.1
            Reporter: John Lonergan

Code below throws the reason 'message' away making it hard to diagnose why a 
split has failed for instance.


        public void handleAsyncException(String message, Throwable exception) {
        if (isRunning) {
        // only fail if the task is still running

Need to pass the message through so that we see it in logs please.


This message was sent by Atlassian JIRA

Reply via email to