code: public void deleteRebalancingState(RebalanceTaskInfo stealInfo) {
          // acquire write lock
          writeLock.lock();
          try {
              RebalancerState rebalancerState = getRebalancerState();
  
              if(!rebalancerState.remove(stealInfo))
                  throw new IllegalArgumentException("Couldn't find " + stealInfo + " in "
                                                     + rebalancerState + " while deleting");
  
              if(rebalancerState.isEmpty()) {
                  logger.debug("Cleaning all rebalancing state");
                  cleanAllRebalancingState();
              } else {
                  put(REBALANCING_STEAL_INFO, rebalancerState);
                  initCache(REBALANCING_STEAL_INFO);
              }
          } finally {
              writeLock.unlock();
          }
      }
docs: Delete the partition steal information from the rebalancer state
  
  @param stealInfo The steal information to delete