diff --git a/theodolite-benchmarks/beam-commons/src/main/java/rocks/theodolite/benchmarks/commons/beam/ConfigurationKeys.java b/theodolite-benchmarks/beam-commons/src/main/java/rocks/theodolite/benchmarks/commons/beam/ConfigurationKeys.java index d6d56b86528f68003626c9f0ea1603aa49e78169..9ab378f8e7aa3fe8f67d4062da2f504671a284bc 100644 --- a/theodolite-benchmarks/beam-commons/src/main/java/rocks/theodolite/benchmarks/commons/beam/ConfigurationKeys.java +++ b/theodolite-benchmarks/beam-commons/src/main/java/rocks/theodolite/benchmarks/commons/beam/ConfigurationKeys.java @@ -29,8 +29,7 @@ public final class ConfigurationKeys { public static final String AGGREGATION_ADVANCE_DAYS = "aggregation.advance.days"; // UC4 - public static final String EMIT_PERIOD_SECONDS = "kafka.window.duration.minutes"; - // public static final String EMIT_PERIOD_MS = "emit.period.ms"; + public static final String EMIT_PERIOD_MS = "emit.period.ms"; public static final String GRACE_PERIOD_MS = "grace.period.ms";