@ Override public void close ( ) throws IOException { try { recordWriter . close ( taskAttemptContext ) ; } catch ( InterruptedException e ) { Thread . interrupted ( ) ; throw new IOException ( "The thread was interrupted" , e ) ; } }
close the file