flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
/**
	 * Recovers all jobs persisted via the submitted job graph store.
	 */
Recovers all jobs persisted via the submitted job graph store.
Recovers all jobs persisted via the submitted job graph store .
private void recoverJobs() {
		log.info("Recovering all persisted jobs.");
		getRpcService().execute(
			() -> {
				final Collection<JobID> jobIds;
				try {
					jobIds = submittedJobGraphStore.getJobIds();
				} catch (Exception e) {
					log.error("Could not recover job ids from the submitted job graph store. Aborting recovery.", e);
					return;
				}
				for (JobID jobId : jobIds) {
					try {
						SubmittedJobGraph submittedJobGraph = submittedJobGraphStore.recoverJobGraph(jobId);
						runAsync(() -> submitJob(submittedJobGraph.getJobGraph(), RpcUtils.INF_TIMEOUT));
					} catch (Exception e) {
						log.error("Could not recover the job graph for " + jobId + '.', e);
					}
				}
			});
	}
private void recoverJobs ( ) { log . info ( "Recovering all persisted jobs." ) ; getRpcService ( ) . execute ( ( ) -> { final Collection < JobID > jobIds ; try { jobIds = submittedJobGraphStore . getJobIds ( ) ; } catch ( Exception e ) { log . error ( "Could not recover job ids from the submitted job graph store. Aborting recovery." , e ) ; return ; } for ( JobID jobId : jobIds ) { try { SubmittedJobGraph submittedJobGraph = submittedJobGraphStore . recoverJobGraph ( jobId ) ; runAsync ( ( ) -> submitJob ( submittedJobGraph . getJobGraph ( ) , RpcUtils . INF_TIMEOUT ) ) ; } catch ( Exception e ) { log . error ( "Could not recover the job graph for " + jobId + '.' , e ) ; } } } ) ; }
Recovers all jobs persisted via the submitted job graph store.
Recovers all jobs persisted via the submitted job graph store .