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

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

              Dates

                Created:
                Updated:
                Resolved: