flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
/**
	 * Clears the state of the dispatcher.
	 *
	 * <p>The state are all currently running jobs.
	 */
Clears the state of the dispatcher.
The state are all currently running jobs.
Clears the state of the dispatcher . The state are all currently running jobs .
private void clearState() throws Exception {
		Exception exception = null;
		for (JobManagerRunner jobManagerRunner : jobManagerRunners.values()) {
			try {
				jobManagerRunner.shutdown();
			} catch (Exception e) {
				exception = ExceptionUtils.firstOrSuppressed(e, exception);
			}
		}
		jobManagerRunners.clear();
		if (exception != null) {
			throw exception;
		}
	}
private void clearState ( ) throws Exception { Exception exception = null ; for ( JobManagerRunner jobManagerRunner : jobManagerRunners . values ( ) ) { try { jobManagerRunner . shutdown ( ) ; } catch ( Exception e ) { exception = ExceptionUtils . firstOrSuppressed ( e , exception ) ; } } jobManagerRunners . clear ( ) ; if ( exception != null ) { throw exception ; } }
Clears the state of the dispatcher.
Clears the state of the dispatcher .
// stop all currently running JobManager since they run in the same process