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

Deprecate checkpoint lock from the Operators API

    XMLWordPrintableJSON

Details

    • Hide
      Deprecated {{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
      Deprecated {{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}}.

    Description

      Drop `this.checkpointLock = getContainingTask().getCheckpointLock();` access (used for example in `ContinuousFileReaderOperator`).

      Redirect users to the mailbox (enqueuing/yielding).

      Attachments

        Issue Links

          relates to

          Sub-task - The sub-task of the issue FLINK-12484 Drop unnecessary locking for code-paths that now use the mailbox

          • Major - Major loss of function.
          • Closed
          links to

          Web Link GitHub Pull Request #10252

          Web Link GitHub Pull Request #10441

          Activity

            People

              roman Roman Khachatryan
              roman Roman Khachatryan
              Votes:
              0 Vote for this issue
              Watchers:
              5 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 - 40m
                  40m