flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointStoreTest.java
/**
	 * Tests that multiple externalized checkpoints can be stored to the same
	 * directory.
	 */
Tests that multiple externalized checkpoints can be stored to the same
directory.
Tests that multiple externalized checkpoints can be stored to the same directory .
@Test
	public void testStoreExternalizedCheckpointsToSameDirectory() throws Exception {
		String root = tmp.newFolder().getAbsolutePath();
		FileSystem fs = FileSystem.get(new Path(root).toUri());
		SavepointV2 savepoint = new SavepointV2(
			1929292,
			CheckpointTestUtils.createOperatorStates(4, 24),
			Collections.<MasterState>emptyList());
		FileStateHandle store1 = SavepointStore.storeExternalizedCheckpointToHandle(root, savepoint);
		fs.exists(store1.getFilePath());
		assertTrue(store1.getFilePath().getPath().contains(SavepointStore.EXTERNALIZED_CHECKPOINT_METADATA_FILE));
		FileStateHandle store2 = SavepointStore.storeExternalizedCheckpointToHandle(root, savepoint);
		fs.exists(store2.getFilePath());
		assertTrue(store2.getFilePath().getPath().contains(SavepointStore.EXTERNALIZED_CHECKPOINT_METADATA_FILE));
	}
@ Test public void testStoreExternalizedCheckpointsToSameDirectory ( ) throws Exception { String root = tmp . newFolder ( ) . getAbsolutePath ( ) ; FileSystem fs = FileSystem . get ( new Path ( root ) . toUri ( ) ) ; SavepointV2 savepoint = new SavepointV2 ( 1929292 , CheckpointTestUtils . createOperatorStates ( 4 , 24 ) , Collections . < MasterState > emptyList ( ) ) ; FileStateHandle store1 = SavepointStore . storeExternalizedCheckpointToHandle ( root , savepoint ) ; fs . exists ( store1 . getFilePath ( ) ) ; assertTrue ( store1 . getFilePath ( ) . getPath ( ) . contains ( SavepointStore . EXTERNALIZED_CHECKPOINT_METADATA_FILE ) ) ; FileStateHandle store2 = SavepointStore . storeExternalizedCheckpointToHandle ( root , savepoint ) ; fs . exists ( store2 . getFilePath ( ) ) ; assertTrue ( store2 . getFilePath ( ) . getPath ( ) . contains ( SavepointStore . EXTERNALIZED_CHECKPOINT_METADATA_FILE ) ) ; }
Tests that multiple externalized checkpoints can be stored to the same
 directory.
Tests that multiple externalized checkpoints can be stored to the same directory .
// Store