public static String[] getExpectedFieldNames(Schema kuduTableSchema) {
        return kuduTableSchema.getColumns().stream().map(ColumnSchema::getName).toArray(String[]::new);
    }
Check schema according to field name
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/kudu/src/main/java/org/apache/inlong/sort/kudu/common/KuduUtils.java