flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphTestUtils.java
/**
	 * Creates an execution graph with on job vertex of parallelism 10, using the given
	 * restart strategy.
	 */
Creates an execution graph with on job vertex of parallelism 10, using the given
restart strategy.
Creates an execution graph with on job vertex of parallelism 10 using the given restart strategy .
public static ExecutionGraph createSimpleTestGraph(RestartStrategy restartStrategy) throws Exception {
		JobVertex vertex = createNoOpVertex(10);
		return createSimpleTestGraph(new JobID(), new SimpleAckingTaskManagerGateway(), restartStrategy, vertex);
	}
public static ExecutionGraph createSimpleTestGraph ( RestartStrategy restartStrategy ) throws Exception { JobVertex vertex = createNoOpVertex ( 10 ) ; return createSimpleTestGraph ( new JobID ( ) , new SimpleAckingTaskManagerGateway ( ) , restartStrategy , vertex ) ; }
Creates an execution graph with on job vertex of parallelism 10, using the given
 restart strategy.
Creates an execution graph with on job vertex of parallelism 10 using the given restart strategy .