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 633fd9d744f27badbfeccb26b8a6f8409ba562ef..0974960a4c61fafb9bf00aecd23aa02f122e33c1 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 @@ -76,7 +76,7 @@ public class PipelineFactory extends AbstractPipelineFactory { this.config.getInt(ConfigurationKeys.EMIT_PERIOD_MS)); final Duration triggerDelay = Duration.standardSeconds( this.config.getInt(ConfigurationKeys.TRIGGER_INTERVAL_SECONDS)); - final Duration gracePeriod = Duration.standardSeconds( // TODO this is wrong + final Duration gracePeriod = Duration.standardSeconds(// TODO this is wrong this.config.getInt(ConfigurationKeys.GRACE_PERIOD_MS)); // Read from Kafka