presto-main/src/main/java/io/prestosql/operator/exchange/LocalExchange.java/LocalExchange/closeSinks
class LocalExchange:        public synchronized void closeSinks(LocalExchangeSinkFactoryId sinkFactoryId)
        {
            closedSinkFactories.add(sinkFactoryId);
            for (LocalExchange localExchange : localExchangeMap.values()) {
                localExchange.getSinkFactory(sinkFactoryId).close();
            }
        }