diff --git a/cruise-control/src/main/java/com/linkedin/kafka/cruisecontrol/executor/ExecutionTaskManager.java b/cruise-control/src/main/java/com/linkedin/kafka/cruisecontrol/executor/ExecutionTaskManager.java
index 66c8dbc12..00aa085c3 100644
--- a/cruise-control/src/main/java/com/linkedin/kafka/cruisecontrol/executor/ExecutionTaskManager.java
+++ b/cruise-control/src/main/java/com/linkedin/kafka/cruisecontrol/executor/ExecutionTaskManager.java
@@ -156,7 +156,7 @@ public synchronized void addExecutionProposals(Collection<ExecutionProposal> pro
     }
   }
 
-  Map<Integer, Integer> getSotedBrokerIdToInterBrokerMoveTaskCountMap() {
+  Map<Integer, Integer> getSortedBrokerIdToInterBrokerMoveTaskCountMap() {
     return _executionTaskPlanner.getSortedBrokerIdToInterBrokerMoveTaskCountMap();
   }
 
diff --git a/cruise-control/src/main/java/com/linkedin/kafka/cruisecontrol/executor/Executor.java b/cruise-control/src/main/java/com/linkedin/kafka/cruisecontrol/executor/Executor.java
index bdf8c82ff..ef4d3aa0f 100644
--- a/cruise-control/src/main/java/com/linkedin/kafka/cruisecontrol/executor/Executor.java
+++ b/cruise-control/src/main/java/com/linkedin/kafka/cruisecontrol/executor/Executor.java
@@ -1632,7 +1632,7 @@ private void interBrokerMoveReplicas() throws InterruptedException, ExecutionExc
       long totalDataToMoveInMB = _executionTaskManager.remainingInterBrokerDataToMoveInMB();
       long startTime = System.currentTimeMillis();
       LOG.info("User task {}: Starting {} inter-broker partition movements.", _uuid, numTotalPartitionMovements);
-      Map<Integer, Integer> map = _executionTaskManager.getSotedBrokerIdToInterBrokerMoveTaskCountMap();
+      Map<Integer, Integer> map = _executionTaskManager.getSortedBrokerIdToInterBrokerMoveTaskCountMap();
       LOG.info("User task {}: Broker Id to Execution Task Count Map: {}", _uuid, map);
       if (!map.isEmpty()) {
         LOG.info("User task {}: Degree of task count skew towards the largest single broker", _uuid,