Added suggestion from review

linkedin · Feb 7, 2022 · 37d010b · 37d010b
1 parent c2cfeb3
commit 37d010b
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/cruise-control/src/main/java/com/linkedin/kafka/cruisecontrol/analyzer/GoalOptimizer.java b/cruise-control/src/main/java/com/linkedin/kafka/cruisecontrol/analyzer/GoalOptimizer.java
@@ -593,11 +593,8 @@ public void run() {
 
         ClusterModel clusterModel = null;
         // We check for Intra broker goals among Default goals - if we have intra broker goals, set replicaPlacementInfo to true
-        if (containsIntraBrokerGoal(_goalsByPriority)) {
-          clusterModel = _loadMonitor.clusterModel(_time.milliseconds(), requirements, _allowCapacityEstimation, true, operationProgress);
-        } else {
-          clusterModel = _loadMonitor.clusterModel(_time.milliseconds(), requirements, _allowCapacityEstimation, operationProgress);
-        }
+        clusterModel = _loadMonitor.clusterModel(_time.milliseconds(), requirements, _allowCapacityEstimation,
+                containsIntraBrokerGoal(_goalsByPriority), operationProgress);
 
         if (!clusterModel.topics().isEmpty()) {
           OptimizerResult result = optimizations(clusterModel, _goalsByPriority, operationProgress);