flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/PendingCheckpointTest.java
/**
	 * FLINK-5985
	 * <p>
	 * This tests checks the inverse of {@link #testNullSubtaskStateLeadsToStatelessTask()}. We want to test that
	 * for subtasks that acknowledge some state are given an entry in the task states of the checkpoint.
	 */
FLINK-5985

This tests checks the inverse of  #testNullSubtaskStateLeadsToStatelessTask(). We want to test that
for subtasks that acknowledge some state are given an entry in the task states of the checkpoint.
FLINK - 5985 This tests checks the inverse of #testNullSubtaskStateLeadsToStatelessTask () . We want to test that for subtasks that acknowledge some state are given an entry in the task states of the checkpoint .
@Test
	public void testNonNullSubtaskStateLeadsToStatefulTask() throws Exception {
		PendingCheckpoint pending = createPendingCheckpoint(CheckpointProperties.forStandardCheckpoint(), null);
		pending.acknowledgeTask(ATTEMPT_ID, mock(TaskStateSnapshot.class), mock(CheckpointMetrics.class));
		Assert.assertFalse(pending.getOperatorStates().isEmpty());
	}
@ Test public void testNonNullSubtaskStateLeadsToStatefulTask ( ) throws Exception { PendingCheckpoint pending = createPendingCheckpoint ( CheckpointProperties . forStandardCheckpoint ( ) , null ) ; pending . acknowledgeTask ( ATTEMPT_ID , mock ( TaskStateSnapshot . class ) , mock ( CheckpointMetrics . class ) ) ; Assert . assertFalse ( pending . getOperatorStates ( ) . isEmpty ( ) ) ; }
FLINK-5985
 <p>
 This tests checks the inverse of {@link #testNullSubtaskStateLeadsToStatelessTask()}.
FLINK - 5985 <p > This tests checks the inverse of { @link #testNullSubtaskStateLeadsToStatelessTask () } .