public void cleanUp(final boolean force) {
    pipeEvents.cleanUp(force);
    response.cleanUp();

    // TODO: clean more fields
  }
NOTE: To ensure idempotency, currently, it is only allowed to call this method within the
{@link ConcurrentHashMap#compute} method of inFlightEvents in {@link
SubscriptionPrefetchingQueue} or {@link SubscriptionPrefetchingQueue#cleanUp}.
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/SubscriptionEvent.java