private void sendRecordsUntil(int targetNumber, SourceContext<RowData> ctx) {
      while (!isCanceled && nextValue < targetNumber) {
        synchronized (ctx.getCheckpointLock()) {
          ctx.collect(
              GenericRowData.of(
                  nextValue++,
                  StringData.fromString(""),
                  LocalDateTime.now().toInstant(ZoneOffset.UTC).toEpochMilli(),
                  TimestampData.fromLocalDateTime(LocalDateTime.now())));
        }
      }
    }
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