From e020671ea10b85956c206259f1825b9eb6fc32e8 Mon Sep 17 00:00:00 2001
From: Allen Wang <allenwang@linkedin.com>
Date: Mon, 25 Nov 2024 17:10:03 -0800
Subject: [PATCH] Fix typo

---
 .../kafka/cruisecontrol/executor/ExecutionTaskManager.java      | 2 +-
 .../com/linkedin/kafka/cruisecontrol/executor/Executor.java     | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

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,