Rename Flink checkpointing interval

theodolite-benchmarks/flink-commons/src/main/java/rocks/theodolite/benchmarks/commons/flink/ConfigurationKeys.java

@@ -25,7 +25,7 @@ public final class ConfigurationKeys {
 
   public static final String CHECKPOINTING = "checkpointing";
 
-  public static final String CHECKPOINTING_INTERVAL_MS = "commit.interval.ms";
+  public static final String CHECKPOINTING_INTERVAL_MS = "checkpointing.interval.ms";
 
   public static final String FLINK_STATE_BACKEND = "flink.state.backend";
 

theodolite-benchmarks/uc1-flink/src/main/resources/META-INF/application.properties

@@ -7,6 +7,5 @@ kafka.output.topic=output
 
 schema.registry.url=http://localhost:8081
 
-num.threads=1
-commit.interval.ms=1000
-cache.max.bytes.buffering=-1
+# Flink configuration
+checkpointing.interval.ms=1000

theodolite-benchmarks/uc2-flink/src/main/resources/META-INF/application.properties

@@ -5,7 +5,8 @@ kafka.bootstrap.servers=localhost:9092
 kafka.input.topic=input
 kafka.output.topic=output
 schema.registry.url=http://localhost:8081
-num.threads=1
-commit.interval.ms=100
-cache.max.bytes.buffering=-1
+
 kafka.window.duration.minutes=1
+
+# Flink configuration
+checkpointing.interval.ms=100

theodolite-benchmarks/uc3-flink/src/main/resources/META-INF/application.properties

@@ -8,7 +8,8 @@ schema.registry.url=http://localhost:8081
 aggregation.duration.days=30
 aggregation.advance.days=1
 aggregation.trigger.interval.seconds=15
-num.threads=1
-commit.interval.ms=100
-cache.max.bytes.buffering=-1
+
 time.zone=Europe/Paris
+
+# Flink configuration
+checkpointing.interval.ms=1000

theodolite-benchmarks/uc4-flink/src/main/resources/META-INF/application.properties

@@ -11,6 +11,6 @@ kafka.output.topic=output
 schema.registry.url=http://localhost:8081
 window.size.ms=1000
 window.grace.ms=0
-num.threads=1
-commit.interval.ms=1000
-cache.max.bytes.buffering=-1
+
+# Flink configuration
+checkpointing.interval.ms=1000