public static TestTableOperations opsWithCommitSucceedButStateUnknown(File temp, String name) {
        return new TestTableOperations(name, temp) {

            @Override
            public void commit(TableMetadata base, TableMetadata updatedMetadata) {
                super.commit(base, updatedMetadata);
                throw new CommitStateUnknownException(new RuntimeException("datacenter on fire"));
            }
        };
    }
Copy from iceberg-flink:iceberg-flink-1.15:1.1.x
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/iceberg/src/test/java/org/apache/inlong/sort/iceberg/sink/util/TestTables.java