code: @Override
  	public void disconnectJobManager(JobID jobId, Exception cause) {
  		closeJobManagerConnection(jobId, cause);
  		jobLeaderService.reconnect(jobId);
  	}
docs: ----------------------------------------------------------------------