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)

Reply via email to