Skip to content
Snippets Groups Projects
Commit 75a365dc authored by Sören Henning's avatar Sören Henning
Browse files

Fix a log statement

parent 928a07d1
No related branches found
No related tags found
No related merge requests found
...@@ -61,7 +61,7 @@ public abstract class AbstractFlinkService { ...@@ -61,7 +61,7 @@ public abstract class AbstractFlinkService {
protected void configureCheckpointing() { protected void configureCheckpointing() {
final boolean checkpointing = this.config.getBoolean(ConfigurationKeys.CHECKPOINTING, true); final boolean checkpointing = this.config.getBoolean(ConfigurationKeys.CHECKPOINTING, true);
final int commitIntervalMs = this.config.getInt(ConfigurationKeys.CHECKPOINTING_INTERVAL_MS); final int commitIntervalMs = this.config.getInt(ConfigurationKeys.CHECKPOINTING_INTERVAL_MS);
LOGGER.info("Set parallelism to: {}.", checkpointing); LOGGER.info("Set checkpointing to: {}.", checkpointing);
if (checkpointing) { if (checkpointing) {
this.env.enableCheckpointing(commitIntervalMs); this.env.enableCheckpointing(commitIntervalMs);
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment