Merge branch 'main' into feature/374-improve-hazelcastjet-structure

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

theodolite-benchmarks/uc3-flink/src/main/java/rocks/theodolite/benchmarks/uc3/flink/ConfigurationKeys.java

@@ -21,7 +21,7 @@ public final class ConfigurationKeys {
 
   public static final String AGGREGATION_ADVANCE_DAYS = "aggregation.advance.days";
 
-  public static final String AGGREGATION_TRIGGER_INTERVAL_SECONDS =
+  public static final String AGGREGATION_TRIGGER_INTERVAL_SECONDS = // NOPMD
       "aggregation.trigger.interval.seconds";
 
   public static final String COMMIT_INTERVAL_MS = "commit.interval.ms";