flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/JobLeaderService.java
/**
	 * Check whether the service monitors the given job.
	 *
	 * @param jobId identifying the job
	 * @return True if the given job is monitored; otherwise false
	 */
Check whether the service monitors the given job.
@param jobId identifying the job
@return True if the given job is monitored; otherwise false
Check whether the service monitors the given job . @param jobId identifying the job @return True if the given job is monitored ; otherwise false
public boolean containsJob(JobID jobId) {
		Preconditions.checkState(JobLeaderService.State.STARTED == state, "The service is currently not running.");
		return jobLeaderServices.containsKey(jobId);
	}
public boolean containsJob ( JobID jobId ) { Preconditions . checkState ( JobLeaderService . State . STARTED == state , "The service is currently not running." ) ; return jobLeaderServices . containsKey ( jobId ) ; }
Check whether the service monitors the given job.
Check whether the service monitors the given job .