[jira] [Created] (FLINK-14857) Deprecate checkpoint lock from the Operators API

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-14857) Deprecate checkpoint lock from the Operators API

Shang Yuanchun (Jira)
Roman Khachatryan created FLINK-14857:
-----------------------------------------

             Summary: Deprecate checkpoint lock from the Operators API
                 Key: FLINK-14857
                 URL: https://issues.apache.org/jira/browse/FLINK-14857
             Project: Flink
          Issue Type: Improvement
          Components: Runtime / Task
    Affects Versions: 1.9.1
            Reporter: Roman Khachatryan


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)