Hi devs,

When working on the FLIP-406[1], I realized that moving all options of
ExecutionCheckpointingOptions(flink-streaming-java) to
CheckpointingOptions(flink-core) depends on relocating the
enum CheckpointingMode(flink-streaming-java) to flink-core module. However,
the CheckpointingMode is annotated as @Public and used by datastream api
like 'CheckpointConfig#setCheckpointingMode'. So I'd like to start a
discussion on moving the CheckpointingMode to flink-core. It is in a little
bit of a hurry if we want the old enum to be entirely removed in Flink 2.x
series, since the deprecation should be shipped in the upcoming Flink 1.19.
I suggest not creating a dedicated FLIP and treating this as a sub-task of
FLIP-406.

I prepared a minimal change of providing new APIs and deprecating the old
ones[2], which could be merged to 1.19 if we agree to do so.

Looking forward to your thoughts! Also cc RMs of 1.19 about this.

[1]
https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=284789560
[2]
https://github.com/apache/flink/commit/9bdd237d0322df8853f1b9e6ae658f77b9175237

Best,
Zakelly

Reply via email to