    @Test
    void testGetTableSchema() throws Exception {

        TableSchema tableSchema = kuduTableSource.getTableSchema();
        assertNotNull(tableSchema);
        assertArrayEquals(getFieldNames(), tableSchema.getFieldNames());
        assertArrayEquals(getFieldDataTypes(), tableSchema.getFieldDataTypes());

    }