Hi Team, Bulk Formats can only have `OnCheckpointRollingPolicy`, which rolls (ONLY) on every checkpoint.
*.withRollingPolicy(OnCheckpointRollingPolicy.build())* Question: What are recommended values related to checkpointing to fsstate, should it be more frequent checkpoints, or longer intervals, how many concurrent checkpoints needs to be allowed, how much should be an ideal pause between each checkpoint. Is there a way to control batch size here other than time ? any recommendations to all the parameters listed below? *Note: *I am trying to improve sink throughput. env.enableCheckpointing(chckptintervalmilli) env.getCheckpointConfig.setCheckpointingMode(CheckpointingMode.valueOf(ChckptMode)) env.getCheckpointConfig.setMinPauseBetweenCheckpoints(chckptintervalmilligap) env.getCheckpointConfig.setCheckpointTimeout(chckptduration) env.getCheckpointConfig.setMaxConcurrentCheckpoints(concurrentchckpt) env.getCheckpointConfig.enableExternalizedCheckpoints(ExternalizedCheckpointCleanup.valueOf(CheckpointCleanup)) env.getCheckpointConfig.setPreferCheckpointForRecovery(CheckpointForCleanup) Thanks, Vijay
