@Override
  public void close() {
    if (closed || aborted) {
      return;
    }
    if (LOGGER.isDebugEnabled()) {
      LOGGER.debug("[StartCloseShuffleSinkHandle]");
    }
    boolean meetError = false;
    Exception firstException = null;
    for (ISink channel : downStreamChannelList) {
      try {
        channel.close();
      } catch (Exception e) {
        if (!meetError) {
          firstException = e;
          meetError = true;
        }
      }
    }
    if (meetError) {
      LOGGER.warn("Error occurred when try to close channel.", firstException);
    }
    sinkListener.onFinish(this);
    closed = true;
    if (LOGGER.isDebugEnabled()) {
      LOGGER.debug("[EndCloseShuffleSinkHandle]");
    }
  }
max bytes this ShuffleSinkHandle can reserve.
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/exchange/sink/ShuffleSinkHandle.java