Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-12477 Change threading-model in StreamTask to a mailbox-based approach
  3. FLINK-12478

Decompose monolithic run-loops in StreamTask implementations into step-wise calls

Attach filesAttach ScreenshotVotersWatch issueWatchersLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

    Details

      Description

      As a first step to introduce a mailbox model, we need to split up the monolithic loops in stream task implementations into stepwise actions. The step-wise actions are still run in a loop, but give us the opportunity to check the mailbox between each step in the future. This mailbox will be added to the loop in a later subtasks.

      We also exclude breaking the stream sources into steps because this is not possible before FLIP-27 is implemented and we need to be compatible to the current source function interface.

        Attachments

          Activity

            People

            • Assignee:
              srichter Stefan Richter
              Reporter:
              srichter Stefan Richter

              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