docs: public void removeJob(JobID jobId) throws Exception {
  		Preconditions.checkState(JobLeaderService.State.STARTED == state, "The service is currently not running.");
  
  		Tuple2<LeaderRetrievalService, JobLeaderService.JobManagerLeaderListener> entry = jobLeaderServices.remove(jobId);
  
  		if (entry != null) {
  			LOG.info("Remove job {} from job leader monitoring.", jobId);
  
  			LeaderRetrievalService leaderRetrievalService = entry.f0;
  			JobLeaderService.JobManagerLeaderListener jobManagerLeaderListener = entry.f1;
  
  			leaderRetrievalService.stop();
  			jobManagerLeaderListener.stop();
  		}
  	}