Matyas Orhidi
02/15/2023, 3:41 PMexecution.checkpointing.interval is seemingly being ignored when testing locally in a minicluster, why is that? I can only enable checkpointing for testing purposes using env.enableCheckpointing(...) 🤷
private static MiniClusterExtension createMiniCluster() {
final Configuration config = new Configuration();
config.setString("state.checkpoints.dir", "file:///tmp/flink/checkpoint");
ignored --> config.setString("execution.checkpointing.interval","10s");
return new MiniClusterExtension(
new MiniClusterResourceConfiguration.Builder()
.setConfiguration(config)
.setNumberSlotsPerTaskManager(2)
.build());
}