code: public static void deleteApplicationFiles(final Map<String, String> env) {
  		final String applicationFilesDir = env.get(YarnConfigKeys.FLINK_YARN_FILES);
  		if (!StringUtils.isNullOrWhitespaceOnly(applicationFilesDir)) {
  			final org.apache.flink.core.fs.Path path = new org.apache.flink.core.fs.Path(applicationFilesDir);
  			try {
  				final org.apache.flink.core.fs.FileSystem fileSystem = path.getFileSystem();
  				if (!fileSystem.delete(path, true)) {
  					LOG.error("Deleting yarn application files under {} was unsuccessful.", applicationFilesDir);
  				}
  			} catch (final IOException e) {
  				LOG.error("Could not properly delete yarn application files directory {}.", applicationFilesDir, e);
  			}
  		} else {
  			LOG.debug("No yarn application files directory set. Therefore, cannot clean up the data.");
  		}
  	}
docs: Deletes the YARN application files, e.g., Flink binaries, libraries, etc., from the remote
  filesystem.
  
  @param env The environment variables.