Skip to content

Commit

Permalink
Fix typo
Browse files Browse the repository at this point in the history
  • Loading branch information
allenxwang committed Nov 26, 2024
1 parent 7eb541d commit e020671
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -156,7 +156,7 @@ public synchronized void addExecutionProposals(Collection<ExecutionProposal> pro
}
}

Map<Integer, Integer> getSotedBrokerIdToInterBrokerMoveTaskCountMap() {
Map<Integer, Integer> getSortedBrokerIdToInterBrokerMoveTaskCountMap() {
return _executionTaskPlanner.getSortedBrokerIdToInterBrokerMoveTaskCountMap();
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand Down

0 comments on commit e020671

Please sign in to comment.