public void finish ( ) throws IOException { boolean success = false ; try { checkInProduceState ( ) ; for ( ResultSubpartition subpartition : subpartitions ) { subpartition . finish ( ) ; } success = true ; } finally { if ( success ) { isFinished = true ; notifyPipelinedConsumers ( ) ; } } }
Finishes the result partition .