@Override
  public void setNoMoreTsBlocksOfOneChannel(int channelIndex) {
    if (closed || aborted) {
      // if this ShuffleSinkHandle has been closed, Driver.close() will attempt to setNoMoreTsBlocks
      // for all the channels
      return;
    }
    try {
      lock.lock();
      if (!hasSetNoMoreTsBlocks[channelIndex]) {
        downStreamChannelList.get(channelIndex).setNoMoreTsBlocks();
        hasSetNoMoreTsBlocks[channelIndex] = true;
      }
    } finally {
      lock.unlock();
    }
  }
max bytes this ShuffleSinkHandle can reserve.
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/exchange/sink/ShuffleSinkHandle.java