diff --git a/theodolite-benchmarks/definitions/uc3-hazelcastjet/resources/uc3-hazelcastjet-deployment.yaml b/theodolite-benchmarks/definitions/uc3-hazelcastjet/resources/uc3-hazelcastjet-deployment.yaml index c9a74a302b61d451514ebb8e8c338be4e34814a4..248dccb83191f273f073912905896be192df8b4c 100644 --- a/theodolite-benchmarks/definitions/uc3-hazelcastjet/resources/uc3-hazelcastjet-deployment.yaml +++ b/theodolite-benchmarks/definitions/uc3-hazelcastjet/resources/uc3-hazelcastjet-deployment.yaml @@ -21,10 +21,6 @@ spec: value: "theodolite-kafka-kafka-bootstrap:9092" - name: SCHEMA_REGISTRY_URL value: "http://theodolite-kafka-schema-registry:8081" - - name: WINDOW_SIZE_IN_SECONDS - value: "50" - - name: HOPPING_SIZE_IN_SECONDS - value: "1" #- name: KUBERNETES_DNS_NAME # value: "titan-ccp-aggregation" - name: KUBERNETES_NAMESPACE 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); }