public static void init() {
    if (pipeModelFixedMemoryBlock != null) {
      return;
    }

    try {
      pipeModelFixedMemoryBlock =
          PipeDataNodeResourceManager.memory()
              .forceAllocateForModelFixedMemoryBlock(0L, PipeMemoryBlockType.BATCH);
    } catch (Exception e) {
      LOGGER.error("init pipe model fixed memory block failed", e);
      // If the allocation fails, we still need to create a default memory block to avoid NPE.
      pipeModelFixedMemoryBlock =
          PipeDataNodeResourceManager.memory()
              .forceAllocateForModelFixedMemoryBlock(0, PipeMemoryBlockType.BATCH);
    }
  }
Discard all events of the given pipe. This method only clears the reference count of the events
and discard them, but do not modify other objects (such as buffers) for simplicity.
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/batch/PipeTabletEventBatch.java