flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/JobLeaderService.java
/**
	 * Remove the given job from being monitored by the job leader service.
	 *
	 * @param jobId identifying the job to remove from monitoring
	 * @throws Exception if an error occurred while stopping the leader retrieval service and listener
	 */
Remove the given job from being monitored by the job leader service.
@param jobId identifying the job to remove from monitoring
@throws Exception if an error occurred while stopping the leader retrieval service and listener
Remove the given job from being monitored by the job leader service . @param jobId identifying the job to remove from monitoring @throws Exception if an error occurred while stopping the leader retrieval service and listener
public void removeJob(JobID jobId) throws Exception {
		Preconditions.checkState(JobLeaderService.State.STARTED == state, "The service is currently not running.");
		Tuple2<LeaderRetrievalService, JobLeaderService.JobManagerLeaderListener> entry = jobLeaderServices.remove(jobId);
		if (entry != null) {
			LOG.info("Remove job {} from job leader monitoring.", jobId);
			LeaderRetrievalService leaderRetrievalService = entry.f0;
			JobLeaderService.JobManagerLeaderListener jobManagerLeaderListener = entry.f1;
			leaderRetrievalService.stop();
			jobManagerLeaderListener.stop();
		}
	}
public void removeJob ( JobID jobId ) throws Exception { Preconditions . checkState ( JobLeaderService . State . STARTED == state , "The service is currently not running." ) ; Tuple2 < LeaderRetrievalService , JobLeaderService . JobManagerLeaderListener > entry = jobLeaderServices . remove ( jobId ) ; if ( entry != null ) { LOG . info ( "Remove job {} from job leader monitoring." , jobId ) ; LeaderRetrievalService leaderRetrievalService = entry . f0 ; JobLeaderService . JobManagerLeaderListener jobManagerLeaderListener = entry . f1 ; leaderRetrievalService . stop ( ) ; jobManagerLeaderListener . stop ( ) ; } }
Remove the given job from being monitored by the job leader service.
Remove the given job from being monitored by the job leader service .