code: public void finish() throws IOException {
  		boolean success = false;
  
  		try {
  			checkInProduceState();
  
  			for (ResultSubpartition subpartition : subpartitions) {
  				subpartition.finish();
  			}
  
  			success = true;
  		}
  		finally {
  			if (success) {
  				isFinished = true;
  
  				notifyPipelinedConsumers();
  			}
  		}
  	}
docs: Finishes the result partition.
  
  <p>After this operation, it is not possible to add further data to the result partition.
  
  <p>For BLOCKING results, this will trigger the deployment of consuming tasks.