diff --git a/theodolite-benchmarks/uc4-beam/src/main/java/rocks/theodolite/benchmarks/uc4/beam/PipelineFactory.java b/theodolite-benchmarks/uc4-beam/src/main/java/rocks/theodolite/benchmarks/uc4/beam/PipelineFactory.java
index e065993b5ce9f233711dd26a3057f07793ee266f..8ea7a8d3e7a49ad889984849fdc3b3700b8bc096 100644
--- a/theodolite-benchmarks/uc4-beam/src/main/java/rocks/theodolite/benchmarks/uc4/beam/PipelineFactory.java
+++ b/theodolite-benchmarks/uc4-beam/src/main/java/rocks/theodolite/benchmarks/uc4/beam/PipelineFactory.java
@@ -72,11 +72,11 @@ public class PipelineFactory extends AbstractPipelineFactory {
     final String configurationTopic =
         this.config.getString(ConfigurationKeys.KAFKA_CONFIGURATION_TOPIC);
 
-    final Duration duration = Duration.standardSeconds(
-        this.config.getInt(ConfigurationKeys.EMIT_PERIOD_SECONDS));
+    final Duration duration = Duration.millis(
+        this.config.getInt(ConfigurationKeys.EMIT_PERIOD_MS));
     final Duration triggerDelay = Duration.standardSeconds(
         this.config.getInt(ConfigurationKeys.TRIGGER_INTERVAL_SECONDS));
-    final Duration gracePeriod = Duration.standardSeconds(
+    final Duration gracePeriod = Duration.standardSeconds( // TODO this is wrong
         this.config.getInt(ConfigurationKeys.GRACE_PERIOD_MS));
 
     // Read from Kafka
diff --git a/theodolite-benchmarks/uc4-beam/src/main/resources/META-INF/application.properties b/theodolite-benchmarks/uc4-beam/src/main/resources/META-INF/application.properties
index 633b5084d03caf481ca4b4902fb0bbd5dee982ef..a5dc4cfaccdb57317d6505bc597f43a7f79a4caf 100644
--- a/theodolite-benchmarks/uc4-beam/src/main/resources/META-INF/application.properties
+++ b/theodolite-benchmarks/uc4-beam/src/main/resources/META-INF/application.properties
@@ -9,7 +9,7 @@ kafka.feedback.topic=aggregation-feedback
 
 schema.registry.url=http://localhost:8081
 
-kafka.window.duration.minutes=1
+emit.period.ms=5000
 trigger.interval=15
 grace.period.ms=270