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

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    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

              Dates

              • Created:
                Updated:
                Resolved:

                Time Tracking

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

                  Issue deployment