flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClient.java
/*
	 * Tells the Cluster to monitor the status of JobId and stop itself once the specified job has finished.
	 */
Tells the Cluster to monitor the status of JobId and stop itself once the specified job has finished.
Tells the Cluster to monitor the status of JobId and stop itself once the specified job has finished .
private void stopAfterJob(JobID jobID) {
		Preconditions.checkNotNull(jobID, "The job id must not be null");
		try {
			Future<Object> replyFuture =
				getJobManagerGateway().ask(
					new ShutdownClusterAfterJob(jobID),
					akkaDuration);
			Await.ready(replyFuture, akkaDuration);
		} catch (Exception e) {
			throw new RuntimeException("Unable to tell application master to stop once the specified job has been finised", e);
		}
	}
private void stopAfterJob ( JobID jobID ) { Preconditions . checkNotNull ( jobID , "The job id must not be null" ) ; try { Future < Object > replyFuture = getJobManagerGateway ( ) . ask ( new ShutdownClusterAfterJob ( jobID ) , akkaDuration ) ; Await . ready ( replyFuture , akkaDuration ) ; } catch ( Exception e ) { throw new RuntimeException ( "Unable to tell application master to stop once the specified job has been finised" , e ) ; } }
Tells the Cluster to monitor the status of JobId and stop itself once the specified job has finished.
Tells the Cluster to monitor the status of JobId and stop itself once the specified job has finished .