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 cbe2e993d66d1824117169e7986311b2663038ee..750f11ab50c5f22edf35c8dd1d0b07b739d7155a 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 905e501b8cb66712f2b245470d96803987a9b93b..4c5a921ce6775e355138e25de2146eec82dc4a18 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 f971390984ee41be1fce54e62f4f43ee2b9c02da..3e8b8e08eacb61a92bc40d16d0c30a65bd1161f8 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 4423cd38c867a50f758437aa8eac8b12c7f10e62..24fb0b0b7044df51e44a7291dfc53ced89008e5f 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 de85fdb88c0462edc9fba58409918470fcb8cb6c..f48b6c6ef1ae747474da54cc43e0c88207f7464e 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