presto-main/src/main/java/io/prestosql/operator/exchange/LocalMergeSourceOperator.java/LocalMergeSourceOperator/finish
class LocalMergeSourceOperator:    @Override
    public void finish()
    {
        sources.forEach(LocalExchangeSource::finish);
    }