Details

    • Release Note:
      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

            Activity

              People

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