code: public JobClient getJobClient(JobGraph jobGraph) throws Exception {
  		Configuration configuration = jobGraph.getJobConfiguration();
  		configuration.setString(ConfigConstants.JOB_MANAGER_IPC_ADDRESS_KEY, "localhost");
  		configuration.setInteger(ConfigConstants.JOB_MANAGER_IPC_PORT_KEY, jobManagerRpcPort);
  		return new JobClient(jobGraph, configuration);
  	}
docs: ------------------------------------------------------------------------