From fdc440de6cfac84a63148047a49fd6158ce4aec4 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?S=C3=B6ren=20Henning?= <soeren.henning@email.uni-kiel.de>
Date: Sat, 26 Nov 2022 16:17:11 +0100
Subject: [PATCH] Rename Flink checkpointing interval
---
.../benchmarks/commons/flink/ConfigurationKeys.java | 2 +-
.../src/main/resources/META-INF/application.properties | 5 ++---
.../src/main/resources/META-INF/application.properties | 9 +++++----
.../src/main/resources/META-INF/application.properties | 9 +++++----
.../src/main/resources/META-INF/application.properties | 6 +++---
5 files changed, 16 insertions(+), 15 deletions(-)
diff --git a/theodolite-benchmarks/flink-commons/src/main/java/rocks/theodolite/benchmarks/commons/flink/ConfigurationKeys.java b/theodolite-benchmarks/flink-commons/src/main/java/rocks/theodolite/benchmarks/commons/flink/ConfigurationKeys.java
index cbe2e993d..750f11ab5 100644
--- a/theodolite-benchmarks/flink-commons/src/main/java/rocks/theodolite/benchmarks/commons/flink/ConfigurationKeys.java
+++ b/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";
diff --git a/theodolite-benchmarks/uc1-flink/src/main/resources/META-INF/application.properties b/theodolite-benchmarks/uc1-flink/src/main/resources/META-INF/application.properties
index 905e501b8..4c5a921ce 100644
--- a/theodolite-benchmarks/uc1-flink/src/main/resources/META-INF/application.properties
+++ b/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
diff --git a/theodolite-benchmarks/uc2-flink/src/main/resources/META-INF/application.properties b/theodolite-benchmarks/uc2-flink/src/main/resources/META-INF/application.properties
index f97139098..3e8b8e08e 100644
--- a/theodolite-benchmarks/uc2-flink/src/main/resources/META-INF/application.properties
+++ b/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
\ No newline at end of file
+
+kafka.window.duration.minutes=1
+
+# Flink configuration
+checkpointing.interval.ms=100
diff --git a/theodolite-benchmarks/uc3-flink/src/main/resources/META-INF/application.properties b/theodolite-benchmarks/uc3-flink/src/main/resources/META-INF/application.properties
index 4423cd38c..24fb0b0b7 100644
--- a/theodolite-benchmarks/uc3-flink/src/main/resources/META-INF/application.properties
+++ b/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
\ No newline at end of file
+
+time.zone=Europe/Paris
+
+# Flink configuration
+checkpointing.interval.ms=1000
diff --git a/theodolite-benchmarks/uc4-flink/src/main/resources/META-INF/application.properties b/theodolite-benchmarks/uc4-flink/src/main/resources/META-INF/application.properties
index de85fdb88..f48b6c6ef 100644
--- a/theodolite-benchmarks/uc4-flink/src/main/resources/META-INF/application.properties
+++ b/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
--
GitLab