flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/ExecutionGraphCheckpointCoordinatorTest.java
/**
	 * Tests that a shut down checkpoint coordinator calls shutdown on
	 * the store and counter.
	 */
Tests that a shut down checkpoint coordinator calls shutdown on
the store and counter.
Tests that a shut down checkpoint coordinator calls shutdown on the store and counter .
@Test
	public void testShutdownCheckpointCoordinator() throws Exception {
		CheckpointIDCounter counter = mock(CheckpointIDCounter.class);
		CompletedCheckpointStore store = mock(CompletedCheckpointStore.class);
		ExecutionGraph graph = createExecutionGraphAndEnableCheckpointing(counter, store);
		graph.failGlobal(new Exception("Test Exception"));
		verify(counter, times(1)).shutdown(JobStatus.FAILED);
		verify(store, times(1)).shutdown(eq(JobStatus.FAILED));
	}
@ Test public void testShutdownCheckpointCoordinator ( ) throws Exception { CheckpointIDCounter counter = mock ( CheckpointIDCounter . class ) ; CompletedCheckpointStore store = mock ( CompletedCheckpointStore . class ) ; ExecutionGraph graph = createExecutionGraphAndEnableCheckpointing ( counter , store ) ; graph . failGlobal ( new Exception ( "Test Exception" ) ) ; verify ( counter , times ( 1 ) ) . shutdown ( JobStatus . FAILED ) ; verify ( store , times ( 1 ) ) . shutdown ( eq ( JobStatus . FAILED ) ) ; }
Tests that a shut down checkpoint coordinator calls shutdown on
 the store and counter.
Tests that a shut down checkpoint coordinator calls shutdown on the store and counter .