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? -- Best Regards, Yuval Itzchakov.
