Minor documentation improvements

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);

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