flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorExternalizedCheckpointsTest.java
/**
	 * Verifies an externalized completed checkpoint instance.
	 *
	 * <p>The provided JobID, checkpoint ID, timestamp need to match. Also, the
	 * external pointer and external metadata need to be notNull and exist (currently
	 * assuming that they are file system based).
	 *
	 * @param checkpoint Completed checkpoint to check.
	 * @param jid JobID of the job the checkpoint belongs to.
	 * @param checkpointId Checkpoint ID of the checkpoint to check.
	 * @param timestamp Timestamp of the checkpoint to check.
	 */
Verifies an externalized completed checkpoint instance.
The provided JobID, checkpoint ID, timestamp need to match. Also, the
external pointer and external metadata need to be notNull and exist (currently
assuming that they are file system based).

@param checkpoint Completed checkpoint to check.
@param jid JobID of the job the checkpoint belongs to.
@param checkpointId Checkpoint ID of the checkpoint to check.
@param timestamp Timestamp of the checkpoint to check.
Verifies an externalized completed checkpoint instance . The provided JobID checkpoint ID timestamp need to match . Also the external pointer and external metadata need to be notNull and exist ( currently assuming that they are file system based ) . @param checkpoint Completed checkpoint to check . @param jid JobID of the job the checkpoint belongs to . @param checkpointId Checkpoint ID of the checkpoint to check . @param timestamp Timestamp of the checkpoint to check .
private static void verifyExternalizedCheckpoint(CompletedCheckpoint checkpoint, JobID jid, long checkpointId, long timestamp) {
		assertEquals(jid, checkpoint.getJobId());
		assertEquals(checkpointId, checkpoint.getCheckpointID());
		assertEquals(timestamp, checkpoint.getTimestamp());
		assertNotNull(checkpoint.getExternalPointer());
		assertNotNull(checkpoint.getExternalizedMetadata());
		FileStateHandle fsHandle = (FileStateHandle) checkpoint.getExternalizedMetadata();
		assertTrue(new File(fsHandle.getFilePath().getPath()).exists());
	}
private static void verifyExternalizedCheckpoint ( CompletedCheckpoint checkpoint , JobID jid , long checkpointId , long timestamp ) { assertEquals ( jid , checkpoint . getJobId ( ) ) ; assertEquals ( checkpointId , checkpoint . getCheckpointID ( ) ) ; assertEquals ( timestamp , checkpoint . getTimestamp ( ) ) ; assertNotNull ( checkpoint . getExternalPointer ( ) ) ; assertNotNull ( checkpoint . getExternalizedMetadata ( ) ) ; FileStateHandle fsHandle = ( FileStateHandle ) checkpoint . getExternalizedMetadata ( ) ; assertTrue ( new File ( fsHandle . getFilePath ( ) . getPath ( ) ) . exists ( ) ) ; }
Verifies an externalized completed checkpoint instance.
Verifies an externalized completed checkpoint instance .