@Override
    public void initializeState(FunctionInitializationContext context) throws Exception {
      nextValueState =
          context
              .getOperatorStateStore()
              .getListState(new ListStateDescriptor<>("nextValue", Integer.class));

      if (nextValueState.get() != null && nextValueState.get().iterator().hasNext()) {
        nextValue = nextValueState.get().iterator().next();
      }
    }
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