code: public void release(Throwable cause) {
  		if (isReleased.compareAndSet(false, true)) {
  			LOG.debug("{}: Releasing {}.", owningTaskName, this);
  
  			// Set the error cause
  			if (cause != null) {
  				this.cause = cause;
  			}
  
  			// Release all subpartitions
  			for (ResultSubpartition subpartition : subpartitions) {
  				try {
  					subpartition.release();
  				}
  				// Catch this in order to ensure that release is called on all subpartitions
  				catch (Throwable t) {
  					LOG.error("Error during release of result subpartition: " + t.getMessage(), t);
  				}
  			}
  		}
  	}
docs: Releases the result partition.