flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Yuval Itzchakov <yuva...@gmail.com>
Subject Passing checkpoint lock object to StreamSourceContexts.getSourceContext after StreamTask.getCheckpointLock deprecation
Date Thu, 09 Apr 2020 17:52:54 GMT
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.

Mime
View raw message