diff --git a/services/venice-controller/src/main/java/com/linkedin/venice/controller/VeniceHelixAdmin.java b/services/venice-controller/src/main/java/com/linkedin/venice/controller/VeniceHelixAdmin.java index 76e3d54e8e..21bfa183ca 100644 --- a/services/venice-controller/src/main/java/com/linkedin/venice/controller/VeniceHelixAdmin.java +++ b/services/venice-controller/src/main/java/com/linkedin/venice/controller/VeniceHelixAdmin.java @@ -614,7 +614,8 @@ public VeniceHelixAdmin( ReflectUtils.loadClass(multiClusterConfigs.getRepushOrchestratorClassName()); RepushOrchestrator repushOrchestrator = ReflectUtils.callConstructor(repushOrchestratorClass, new Class[0], new Object[0]); - compactionManager = new CompactionManager(repushOrchestrator); + compactionManager = + new CompactionManager(repushOrchestrator, multiClusterConfigs.getTimeSinceLastLogCompactionThresholdMS()); } List initRoutines = new ArrayList<>();