Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-20081

ExecutorNotifier should run handler in the main thread when receive an exception from the callable.

    XMLWordPrintableJSON

    Details

      Description

      Currently the ExecutorNotifier runs the handler in the worker thread if there is an exception thrown from the callable. This breaks the threading model and prevents an exception from bubbling up to fail the job.

      Another issue is that right now, when an exception bubbles up from the SourceCoordinator, the UncaughtExceptionHandler will call System.exit(-17) and kill the JM. This is too much. Instead, we should just fail the job to trigger a failover.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                becket_qin Jiangjie Qin
                Reporter:
                becket_qin Jiangjie Qin
              • Votes:
                0 Vote for this issue
                Watchers:
                4 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: