@Test
    public void testCreateSink() {

        Map<String, String> properties = getProperties();
        DynamicTableSink actualSink = createTableSink(testSchema, properties);

        KuduTableInfo kuduTableInfo = KuduTableInfo.builder()
                .masters(masters)
                .tableName(tableName)
                .fieldNames(testSchema.getColumnNames().toArray(new String[0]))
                .dataTypes(testSchema.getColumnDataTypes().toArray(new DataType[0]))
                .flushMode(FlushMode.AUTO_FLUSH_BACKGROUND)
                .build();
        DynamicTableSink expectedSink =
                new KuduDynamicTableSink(
                        kuduTableInfo,
                        new Configuration(),
                        null,
                        null);

        assertEquals(expectedSink, actualSink);
    }
The unit tests for {@link KuduDynamicTableFactory}.
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/kudu/src/test/java/org/apache/inlong/sort/connector/kudu/KuduTableFactoryTest.java