[
https://issues.apache.org/jira/browse/FLINK-14857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-14857:
--------------------------------------
Release Note:
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)
