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
/**
	 * Deletes a savepoint directory.
	 *
	 * @param savepointDirectory Recursively deletes the given directory
	 * @throws IOException FileSystem operation failures are forwarded
	 */
Deletes a savepoint directory.
@param savepointDirectory Recursively deletes the given directory
@throws IOException FileSystem operation failures are forwarded
Deletes a savepoint directory . @param savepointDirectory Recursively deletes the given directory @throws IOException FileSystem operation failures are forwarded
public static void deleteSavepointDirectory(@Nonnull String savepointDirectory) throws IOException {
		Path path = new Path(savepointDirectory);
		FileSystem fs = FileSystem.get(path.toUri());
		fs.delete(path, true);
	}
public static void deleteSavepointDirectory ( @ Nonnull String savepointDirectory ) throws IOException { Path path = new Path ( savepointDirectory ) ; FileSystem fs = FileSystem . get ( path . toUri ( ) ) ; fs . delete ( path , true ) ; }
Deletes a savepoint directory.
Deletes a savepoint directory .