From 1327ffe1d16166bc17283e97478cd76203f4226c Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?S=C3=B6ren=20Henning?= <soeren.henning@email.uni-kiel.de>
Date: Fri, 25 Nov 2022 14:01:55 +0100
Subject: [PATCH] Minor documentation improvements
---
.../theodolite/benchmarks/uc2/flink/HistoryServiceFlinkJob.java | 2 +-
.../uc3-beam/src/main/resources/META-INF/application.properties | 1 +
2 files changed, 2 insertions(+), 1 deletion(-)
diff --git a/theodolite-benchmarks/uc2-flink/src/main/java/rocks/theodolite/benchmarks/uc2/flink/HistoryServiceFlinkJob.java b/theodolite-benchmarks/uc2-flink/src/main/java/rocks/theodolite/benchmarks/uc2/flink/HistoryServiceFlinkJob.java
index 5a34d17a8..eda3c1a98 100644
--- a/theodolite-benchmarks/uc2-flink/src/main/java/rocks/theodolite/benchmarks/uc2/flink/HistoryServiceFlinkJob.java
+++ b/theodolite-benchmarks/uc2-flink/src/main/java/rocks/theodolite/benchmarks/uc2/flink/HistoryServiceFlinkJob.java
@@ -65,7 +65,7 @@ public final class HistoryServiceFlinkJob extends AbstractFlinkService {
.map(t -> {
final String key = t.f0;
final String value = t.f1.toString();
- LOGGER.info("{}: {}", key, value);
+ LOGGER.info("{}: {}", key, value); // TODO align implementations
return new Tuple2<>(key, value);
}).name("map").returns(Types.TUPLE(Types.STRING, Types.STRING))
.addSink(kafkaSink).name("[Kafka Producer] Topic: " + outputTopic);
diff --git a/theodolite-benchmarks/uc3-beam/src/main/resources/META-INF/application.properties b/theodolite-benchmarks/uc3-beam/src/main/resources/META-INF/application.properties
index 0fe4b240d..1c41e1500 100644
--- a/theodolite-benchmarks/uc3-beam/src/main/resources/META-INF/application.properties
+++ b/theodolite-benchmarks/uc3-beam/src/main/resources/META-INF/application.properties
@@ -11,6 +11,7 @@ schema.registry.url=http://localhost:8081
aggregation.duration.days=30
aggregation.advance.days=1
+# in seconds
trigger.interval=15
num.threads=1
--
GitLab