masteryhx commented on code in PR #24381:
URL: https://github.com/apache/flink/pull/24381#discussion_r1513788931
##########
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/CheckpointConfig.java:
##########
@@ -178,7 +178,9 @@ public boolean isCheckpointingEnabled() {
* Gets the checkpointing mode (exactly-once vs. at-least-once).
*
* @return The checkpointing mode.
+ * @deprecated Use {@link #getCheckpointMode} instead.
*/
+ @Deprecated
public CheckpointingMode getCheckpointingMode() {
return
configuration.get(ExecutionCheckpointingOptions.CHECKPOINTING_MODE);
Review Comment:
IIUC, we should replace all internal usages of original CheckpointMode and
docs with new one except for the user-facing interface, right?
I'd suggest to transform to the new CheckpointMode for all original public
interfaces, and use the new one for other inner places.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
