@Test
  public void testWrite() throws Exception {
    tableLoader = MixedFormatTableLoader.of(TableTestHelper.TEST_TABLE_ID, catalogBuilder);

    JobGraph jobGraph = createJobGraph(tableLoader, FLINK_SCHEMA, true);
    final Configuration config = new Configuration();
    config.setString(RestOptions.BIND_PORT, "18081-19000");
    final MiniClusterConfiguration cfg =
        new MiniClusterConfiguration.Builder()
            .setNumTaskManagers(1)
            .setNumSlotsPerTaskManager(NUM_SOURCES)
            .setConfiguration(config)
            .build();

    try (MiniCluster miniCluster = new MiniCluster(cfg)) {
      miniCluster.start();
      miniCluster.executeJobBlocking(jobGraph);
    }

    KeyedTable keyedTable = tableLoader.loadMixedFormatTable().asKeyedTable();
    checkResult(keyedTable, NUM_RECORDS * NUM_SOURCES);
  }
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