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

Drop unnecessary locking for code-paths that now use the mailbox

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

    Details

    • Release Note:
      Hide
      Removed deprecated in Flink 1.10 {{getCheckpointLock}} method of the {{org.apache.flink.streaming.runtime.tasks.StreamTask}} class.

      Users should use {{MailboxExecutor}} to run actions that require synchronization with the task's thread (e.g. collecting output produced by an external thread). {{MailboxExecutor#yield}} or {{MailboxExecutor#tryYield}} methods can be used for actions that should give control to other actions temporarily, if the current operator is blocked.

      {{MailboxExecutor}} can be accessed by using {{YieldingOperatorFactory}}. Example usage can be found in the {{AsyncWaitOperator}}.
      Show
      Removed deprecated in Flink 1.10 {{getCheckpointLock}} method of the {{org.apache.flink.streaming.runtime.tasks.StreamTask}} class. Users should use {{MailboxExecutor}} to run actions that require synchronization with the task's thread (e.g. collecting output produced by an external thread). {{MailboxExecutor#yield}} or {{MailboxExecutor#tryYield}} methods can be used for actions that should give control to other actions temporarily, if the current operator is blocked. {{MailboxExecutor}} can be accessed by using {{YieldingOperatorFactory}}. Example usage can be found in the {{AsyncWaitOperator}}.

      Attachments

        Activity

          People

          • Assignee:
            roman_khachatryan Roman Khachatryan
            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 - 50m
              50m

                Issue deployment