One thing that had just occurred to me is that the context is later used to emit watermarks and send elements downstream using ctx.collect. Perhaps all these operations should now be switched to the new mailbox executor instead?
On Thu, Apr 9, 2020 at 8:52 PM Yuval Itzchakov <yuva...@gmail.com> wrote: > 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. > -- Best Regards, Yuval Itzchakov.
