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

Stateful Function jobs fail to restore after losing task slots using the new Flink scheduler

    XMLWordPrintableJSON

    Details

      Description

      The following exception is being thrown indefinitely once a worker is lost:

      org.apache.flink.util.FlinkException: Multi task slot is not local and, thus, does not fulfill the co-location constraint.
      

      This is caused by FLINK-16139, which is fixed in Flink 1.10.1.

      To unblock the release for Stateful Functions 2.0.0, which depends on Flink 1.10.0,
      for StateFun 2.0.0 we can use the old legacy scheduler for the time being.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                igal Igal Shilman
                Reporter:
                tzulitai Tzu-Li (Gordon) Tai
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved:

                  Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 20m
                  20m