@ Override public void close ( ) throws IOException { if ( Files . exists ( outFile ) ) { Files . delete ( outFile ) ; } if ( Files . exists ( errFile ) ) { Files . delete ( errFile ) ; } if ( Files . exists ( resultFile ) ) { Files . delete ( resultFile ) ; } }
Clean up the files that have been created on the local worker file system . Without this expect both performance issues and eventual failure