flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/savepoint/SavepointStore.java
/**
	 * Stores the savepoint metadata file.
	 *
	 * @param <T>       Savepoint type
	 * @param directory Target directory to store savepoint in
	 * @param savepoint Savepoint to be stored
	 * @return Path of stored savepoint
	 * @throws IOException Failures during store are forwarded
	 */
Stores the savepoint metadata file.
Stores the savepoint metadata file .
public static <T extends Savepoint> String storeSavepoint(String directory, T savepoint) throws IOException {
		FileStateHandle metadataFileHandle = storeSavepointToHandle(directory,
			SAVEPOINT_METADATA_FILE, savepoint);
		return metadataFileHandle.getFilePath().getParent().toString();
	}
public static < T extends Savepoint > String storeSavepoint ( String directory , T savepoint ) throws IOException { FileStateHandle metadataFileHandle = storeSavepointToHandle ( directory , SAVEPOINT_METADATA_FILE , savepoint ) ; return metadataFileHandle . getFilePath ( ) . getParent ( ) . toString ( ) ; }
Stores the savepoint metadata file.
Stores the savepoint metadata file .
// write and create the file handle // we return the savepoint directory path here! // The directory path also works to resume from and is more elegant than the direct // metadata file pointer