@Override
  public void setNoMoreTsBlocks() {
    if (closed || aborted) {
      return;
    }
    try {
      lock.lock();
      for (int i = 0; i < downStreamChannelList.size(); i++) {
        if (!hasSetNoMoreTsBlocks[i]) {
          downStreamChannelList.get(i).setNoMoreTsBlocks();
          hasSetNoMoreTsBlocks[i] = true;
        }
      }
      sinkListener.onEndOfBlocks(this);
    } 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