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

Exception thrown from JobMaster.startScheduling() may be ignored.

    XMLWordPrintableJSON

    Details

      Description

      Currently JobMaster.resetAndStartScheduler() invokes startScheduling() in a thenRun clause without exceptionally or handle to handle exceptions. The job may hang if an exception is thrown when starting scheduling, e.g. failed to create operator coordinators. 

        Attachments

          Issue Links

            Activity

              People

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

                Dates

                • Created:
                  Updated:
                  Resolved: