Passing checkpoint lock object to StreamSourceContexts.getSourceContext after StreamTask.getCheckpointLock deprecation

Posted by Yuval Itzchakov on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Passing-checkpoint-lock-object-to-StreamSourceContexts-getSourceContext-after-StreamTask-getCheckpoin-tp34206.html

Hi,

I have an implementation of a custom source, which uses StreamSourceContexts.getSourceContext (https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSourceContexts.java#L46) which has a checkpointLock argument that's used for watermark emission and possibly additional work.

Flink 1.10 marks StreamTask.getCheckpointLock as deprecated and points to using YieldingOperatorFactory instead.

Question is, with the above method now being deprecated, which object should we pass to getSourceContext for the required checkpointLock?

--