From 9bac5a9964a69e2524a1e8f75d01b2ad6ac42830 Mon Sep 17 00:00:00 2001 From: xyuanlu Date: Tue, 26 Sep 2023 16:47:27 -0700 Subject: [PATCH] add todo --- .../helix/controller/stages/CurrentStateComputationStage.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/helix-core/src/main/java/org/apache/helix/controller/stages/CurrentStateComputationStage.java b/helix-core/src/main/java/org/apache/helix/controller/stages/CurrentStateComputationStage.java index 4eb4004af2..51abca36b3 100644 --- a/helix-core/src/main/java/org/apache/helix/controller/stages/CurrentStateComputationStage.java +++ b/helix-core/src/main/java/org/apache/helix/controller/stages/CurrentStateComputationStage.java @@ -113,6 +113,8 @@ public void process(ClusterEvent event) throws Exception { reportResourcePartitionCapacityMetrics(dataProvider.getAsyncTasksThreadPool(), clusterStatusMonitor, dataProvider.getResourceConfigMap().values()); + // TODO: we only need to compute when there are resource using Waged. We should + // do this as perf improvement in future. WagedInstanceCapacity capacityProvider = new WagedInstanceCapacity(dataProvider); WagedResourceWeightsProvider weightProvider = new WagedResourceWeightsProvider(dataProvider);