presto-main/src/main/java/io/prestosql/operator/exchange/LocalExchange.java/LocalExchangeFactory/noMoreSinkFactories
class LocalExchangeFactory:        public synchronized void noMoreSinkFactories()
        {
            noMoreSinkFactories = true;
        }