[
https://issues.apache.org/jira/browse/FLINK-14857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-14857:
-----------------------------------
Release Note:
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 {{AsyncWaitOperator}}.
was:
Deprecated getCheckpointLock method of the
org.apache.flink.streaming.runtime.tasks.StreamTask class.
Users should use mailbox executor to run StreamTask actions that require
synchronization (e.g. checkpointing, collecting output).
For other (non-StreamTask) actions other synchronization means can be used.
MailboxExecutor yield or tryYield methods can be used for actions that should
give control to other actions temporarily.
Example use of mailbox executor can be found in AsyncWaitOperator.
> Deprecate checkpoint lock from the Operators API
> ------------------------------------------------
>
> Key: FLINK-14857
> URL: https://issues.apache.org/jira/browse/FLINK-14857
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Task
> Affects Versions: 1.9.1
> Reporter: Roman Khachatryan
> Assignee: Roman Khachatryan
> Priority: Major
> Labels: pull-request-available
> Time Spent: 10m
> Remaining Estimate: 0h
>
> Drop `this.checkpointLock = getContainingTask().getCheckpointLock();` access
> (used for example in `ContinuousFileReaderOperator`).
> Redirect users to the mailbox (enqueuing/yielding).
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
