docs: public void removeJob(JobID jobId) throws Exception {
  		LOG.debug("Remove job {} from job leader id monitoring.", jobId);
  
  		JobLeaderIdListener listener = jobLeaderIdListeners.remove(jobId);
  
  		if (listener != null) {
  			listener.stop();
  		}
  	}