From e6d2bb4c249b5e3e5666e0f02cf83ea0635608c3 Mon Sep 17 00:00:00 2001 From: Whitney Deng Date: Tue, 17 Dec 2024 11:53:28 -0800 Subject: [PATCH] [controller] ConfigKeys::TIME_SINCE_LAST_LOG_COMPACTION_THRESHOLD_MS cont'd: update CompactionManager init --- .../java/com/linkedin/venice/controller/VeniceHelixAdmin.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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<>();