public static void assertTableRecords(
            Table table, List<Record> expected, Duration checkInterval, int maxCheckCount)
            throws IOException, InterruptedException {
        for (int i = 0; i < maxCheckCount; ++i) {
            if (equalsRecords(expected, tableRecords(table), table.schema())) {
                break;
            } else {
                Thread.sleep(checkInterval.toMillis());
            }
        }
        // success or failure, assert on the latest table state
        assertRecordsEqual(expected, tableRecords(table), table.schema());
    }
Assert table contains the expected list of records after waiting up to {@code maxCheckCount}
with {@code checkInterval}
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/iceberg/src/test/java/org/apache/inlong/sort/iceberg/sink/util/SimpleDataUtil.java