private static void flushDataRegion() {
    try {
      StorageEngine.getInstance().operateFlush(new TFlushReq());
      PROGRESS_REPORT_COUNT.set(0);
      LAST_PROGRESS_REPORT_TIME.set(0);
      LOGGER.info("Force flush all data regions because of last progress report time.");
    } catch (final Exception e) {
      LOGGER.warn(
          "Failed to flush all data regions, please check the error message: {}",
          e.getMessage(),
          e);
    }
  }
The {@link PipeTerminateEvent} is an {@link EnrichedEvent} that controls the termination of pipe,
that is, when the historical {@link PipeTsFileInsertionEvent}s are all processed, this will be
reported next and mark the {@link PipeDataNodeTask} as completed. WARNING: This event shall never
be discarded.
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/terminate/PipeTerminateEvent.java