@Override
    public void notifyCheckpointComplete(long checkpointId) throws Exception {
      if (isWaitingCheckpointComplete && snapshottedAfterAllRecordsOutput) {
        CountDownLatch latch = LATCH_MAP.get(latchId);
        latch.countDown();
      }

      hasCompletedCheckpoint = true;
    }
Whether the test is executing in a scenario that induces a failover. This doesn't mean that
this source induces the failover.
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/test/java/org/apache/amoro/flink/write/MixedFormatFileWriterITCase.java