diff --git a/theodolite-benchmarks/flink-commons/src/main/java/rocks/theodolite/benchmarks/commons/flink/AbstractFlinkService.java b/theodolite-benchmarks/flink-commons/src/main/java/rocks/theodolite/benchmarks/commons/flink/AbstractFlinkService.java index 662692c732cf65965dc689be5ded8125b4488233..03e79788631d0e236a78cf019bef3984bcd1ba40 100644 --- a/theodolite-benchmarks/flink-commons/src/main/java/rocks/theodolite/benchmarks/commons/flink/AbstractFlinkService.java +++ b/theodolite-benchmarks/flink-commons/src/main/java/rocks/theodolite/benchmarks/commons/flink/AbstractFlinkService.java @@ -61,7 +61,7 @@ public abstract class AbstractFlinkService { protected void configureCheckpointing() { final boolean checkpointing = this.config.getBoolean(ConfigurationKeys.CHECKPOINTING, true); final int commitIntervalMs = this.config.getInt(ConfigurationKeys.CHECKPOINTING_INTERVAL_MS); - LOGGER.info("Set parallelism to: {}.", checkpointing); + LOGGER.info("Set checkpointing to: {}.", checkpointing); if (checkpointing) { this.env.enableCheckpointing(commitIntervalMs); }