flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-runtime/src/main/java/org/apache/flink/runtime/client/JobClient.java
/**
	 * Sends a [[JobGraph]] to the JobClient actor specified by jobClient which submits it then to
	 * the JobManager. The method blocks until the job has finished or the JobManager is no longer
	 * alive. In the former case, the [[SerializedJobExecutionResult]] is returned and in the latter
	 * case a [[JobExecutionException]] is thrown.
	 *
	 * @param actorSystem The actor system that performs the communication.
	 * @param config The cluster wide configuration.
	 * @param highAvailabilityServices Service factory for high availability services
	 * @param jobGraph    JobGraph describing the Flink job
	 * @param timeout     Timeout for futures
	 * @param sysoutLogUpdates prints log updates to system out if true
	 * @param classLoader The class loader for deserializing the results
	 * @return The job execution result
	 * @throws JobExecutionException Thrown if the job
	 *                                                               execution fails.
	 */
Sends a [[JobGraph]] to the JobClient actor specified by jobClient which submits it then to
the JobManager. The method blocks until the job has finished or the JobManager is no longer
alive. In the former case, the [[SerializedJobExecutionResult]] is returned and in the latter
case a [[JobExecutionException]] is thrown.

@param actorSystem The actor system that performs the communication.
@param config The cluster wide configuration.
Sends a [[ JobGraph ]] to the JobClient actor specified by jobClient which submits it then to the JobManager . The method blocks until the job has finished or the JobManager is no longer alive . In the former case the [[ SerializedJobExecutionResult ]] is returned and in the latter case a [[ JobExecutionException ]] is thrown . @param actorSystem The actor system that performs the communication . @param config The cluster wide configuration .
public static JobExecutionResult submitJobAndWait(
			ActorSystem actorSystem,
			Configuration config,
			HighAvailabilityServices highAvailabilityServices,
			JobGraph jobGraph,
			FiniteDuration timeout,
			boolean sysoutLogUpdates,
			ClassLoader classLoader) throws JobExecutionException {
		JobListeningContext jobListeningContext = submitJob(
				actorSystem,
				config,
				highAvailabilityServices,
				jobGraph,
				timeout,
				sysoutLogUpdates,
				classLoader);
		return awaitJobResult(jobListeningContext);
	}
public static JobExecutionResult submitJobAndWait ( ActorSystem actorSystem , Configuration config , HighAvailabilityServices highAvailabilityServices , JobGraph jobGraph , FiniteDuration timeout , boolean sysoutLogUpdates , ClassLoader classLoader ) throws JobExecutionException { JobListeningContext jobListeningContext = submitJob ( actorSystem , config , highAvailabilityServices , jobGraph , timeout , sysoutLogUpdates , classLoader ) ; return awaitJobResult ( jobListeningContext ) ; }
Sends a [[JobGraph]] to the JobClient actor specified by jobClient which submits it then to
 the JobManager.
Sends a [[ JobGraph ]] to the JobClient actor specified by jobClient which submits it then to the JobManager .