@Override
  public synchronized void setNoMoreTsBlocks() {
    if (LOGGER.isDebugEnabled()) {
      LOGGER.debug("[StartSetNoMoreTsBlocks]");
    }
    if (aborted || closed) {
      return;
    }
    executorService.submit(new SendEndOfDataBlockEventTask());
  }
max bytes this SinkChannel can reserve.
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/exchange/sink/SinkChannel.java