Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-18689 Deterministic Slot Sharing
  3. FLINK-18957

Implement bulk fulfil-ability timeout tracking for shared slots

Agile BoardRank to TopRank to BottomAttach filesAttach ScreenshotBulk Copy AttachmentsBulk Move AttachmentsVotersWatch issueWatchersConvert to IssueLinkCloneLabelsUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    Description

      Track fulfil-ability of required physical slots for all SharedSlot(s) (no matter whether they are created at this bulk or not) with timeout. This ensures we will not wait indefinitely if the required slots for this bulk cannot be fully fulfilled at the same time.

      1. Create a LogicalSlotRequestBulk to track all physical requests and logical slot requests (logical slot requests only which belong to the bulk)
      2. Mark physical slot request fulfilled in LogicalSlotRequestBulk, once its future is done
      3. If any physical slot request fails then clear the LogicalSlotRequestBulk to stop the fulfil-ability check
      4. Schedule a fulfil-ability check in LogicalSlotRequestBulkChecker for the LogicalSlotRequestBulk
      5. In case of timeout:
        1. cancel/fail the logical slot futures of the bulk in SharedSlot(s)
        2. remove

      Attachments

        Activity

          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            azagrebin Andrey Zagrebin
            azagrebin Andrey Zagrebin
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Slack

                Issue deployment