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
/**
	 * Removes the savepoint meta data w/o loading and disposing it.
	 *
	 * @param path Path of savepoint to remove
	 * @throws IOException Failures during disposal are forwarded
	 */
Removes the savepoint meta data w/o loading and disposing it.
@param path Path of savepoint to remove
@throws IOException Failures during disposal are forwarded
Removes the savepoint meta data w / o loading and disposing it . @param path Path of savepoint to remove @throws IOException Failures during disposal are forwarded
public static void removeSavepointFile(String path) throws IOException {
		Preconditions.checkNotNull(path, "Path");
		try {
			LOG.info("Removing savepoint: {}.", path);
			Path filePath = new Path(path);
			FileSystem fs = FileSystem.get(filePath.toUri());
			if (fs.exists(filePath)) {
				if (!fs.delete(filePath, true)) {
					throw new IOException("Failed to delete " + filePath + ".");
				}
			} else {
				throw new IllegalArgumentException("Invalid path '" + filePath.toUri() + "'.");
			}
		} catch (Throwable t) {
			throw new IOException("Failed to dispose savepoint " + path + ".", t);
		}
	}
public static void removeSavepointFile ( String path ) throws IOException { Preconditions . checkNotNull ( path , "Path" ) ; try { LOG . info ( "Removing savepoint: {}." , path ) ; Path filePath = new Path ( path ) ; FileSystem fs = FileSystem . get ( filePath . toUri ( ) ) ; if ( fs . exists ( filePath ) ) { if ( ! fs . delete ( filePath , true ) ) { throw new IOException ( "Failed to delete " + filePath + "." ) ; } } else { throw new IllegalArgumentException ( "Invalid path '" + filePath . toUri ( ) + "'." ) ; } } catch ( Throwable t ) { throw new IOException ( "Failed to dispose savepoint " + path + "." , t ) ; } }
Removes the savepoint meta data w/o loading and disposing it.
Removes the savepoint meta data w / o loading and disposing it .