@Override
  public void close(TaskAttemptContext context) throws IOException, InterruptedException {
    try {
      internalWriter.close();
      // release after the writer closes in case it is used for a last flush
    } finally {
      if (codecFactory != null) {
        codecFactory.release();
      }
      if (memoryManager != null) {
        memoryManager.removeWriter(internalWriter);
      }
    }
  }
@Override
  public void close(TaskAttemptContext context) throws IOException, InterruptedException {
    try {
      internalWriter.close();
      
    } finally {
      if (codecFactory != null) {
        codecFactory.release();
      }
      if (memoryManager != null) {
        memoryManager.removeWriter(internalWriter);
      }
    }
  }
@ Override public void close ( TaskAttemptContext context ) throws IOException , InterruptedException { try { internalWriter . close ( ) ; // release after the writer closes in case it is used for a last flush } finally { if ( codecFactory != null ) { codecFactory . release ( ) ; } if ( memoryManager != null ) { memoryManager . removeWriter ( internalWriter ) ; } } }
{@inheritDoc}
{