Skip to content
Snippets Groups Projects

Align UC4 implementations among engines

Merged Sören Henning requested to merge align-uc4-among-engines into main
1 file
+ 1
1
Compare changes
  • Side-by-side
  • Inline
@@ -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
Loading