flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java
/**
	 * Tests that disabled checkpointing sets the checkpointing interval to Long.MAX_VALUE.
	 */
Tests that disabled checkpointing sets the checkpointing interval to Long.MAX_VALUE.
Tests that disabled checkpointing sets the checkpointing interval to Long . MAX_VALUE .
@Test
	public void testDisabledCheckpointing() throws Exception {
		StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
		StreamGraph streamGraph = new StreamGraph(env);
		assertFalse("Checkpointing enabled", streamGraph.getCheckpointConfig().isCheckpointingEnabled());
		JobGraph jobGraph = StreamingJobGraphGenerator.createJobGraph(streamGraph);
		JobCheckpointingSettings snapshottingSettings = jobGraph.getCheckpointingSettings();
		assertEquals(Long.MAX_VALUE, snapshottingSettings.getCheckpointCoordinatorConfiguration().getCheckpointInterval());
	}
@ Test public void testDisabledCheckpointing ( ) throws Exception { StreamExecutionEnvironment env = StreamExecutionEnvironment . getExecutionEnvironment ( ) ; StreamGraph streamGraph = new StreamGraph ( env ) ; assertFalse ( "Checkpointing enabled" , streamGraph . getCheckpointConfig ( ) . isCheckpointingEnabled ( ) ) ; JobGraph jobGraph = StreamingJobGraphGenerator . createJobGraph ( streamGraph ) ; JobCheckpointingSettings snapshottingSettings = jobGraph . getCheckpointingSettings ( ) ; assertEquals ( Long . MAX_VALUE , snapshottingSettings . getCheckpointCoordinatorConfiguration ( ) . getCheckpointInterval ( ) ) ; }
Tests that disabled checkpointing sets the checkpointing interval to Long.MAX_VALUE.
Tests that disabled checkpointing sets the checkpointing interval to Long . MAX_VALUE .