code: private synchronized void rebalanceJobNode(List<String> nodes) {
  		while(updatingStatus);
  		Collection<JobConfig> jobs = schedulerConfgs.values();
  		int nodeIndex = 0;
  		for (JobConfig job : jobs) {
  			String nodeId = nodes.get(nodeIndex++);
  			if(!StringUtils.equals(job.getCurrentNodeId(), nodeId)){				
  				job.setCurrentNodeId(nodeId);
  				logger.info("rebalance Job[{}-{}] To Node[{}] ",job.getGroupName(),job.getJobName(),nodeId);
  			}
  			if(nodeIndex >= nodes.size()){
  				nodeIndex = 0;
  			}
  			//
  			updateJobConfig(job);
  		}
  		
  	}
docs: 重新分配执行节点
  @param nodes