flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphStopTest.java
/**
	 * Tests that STOP is only supported if all sources are stoppable
	 */
Tests that STOP is only supported if all sources are stoppable
Tests that STOP is only supported if all sources are stoppable
@Test
	public void testStopIfSourcesNotStoppable() throws Exception {
		final ExecutionGraph graph = ExecutionGraphTestUtils.createSimpleTestGraph();
		try {
			graph.stop();
			fail("exception expected");
		}
		catch (StoppingException e) {
		}
	}
@ Test public void testStopIfSourcesNotStoppable ( ) throws Exception { final ExecutionGraph graph = ExecutionGraphTestUtils . createSimpleTestGraph ( ) ; try { graph . stop ( ) ; fail ( "exception expected" ) ; } catch ( StoppingException e ) { } }
Tests that STOP is only supported if all sources are stoppable
Tests that STOP is only supported if all sources are stoppable
// expected