private Path getYarnFilesDir ( final ApplicationId appId ) throws IOException { final FileSystem fileSystem = FileSystem . get ( yarnConfiguration ) ; final Path homeDir = fileSystem . getHomeDirectory ( ) ; return new Path ( homeDir , ".flink/" + appId + ' ' ) ; }
Returns the Path where the YARN application files should be uploaded to .