private void initializeClickHouseTable() {
        try {
            Class.forName(CLICK_HOUSE_CONTAINER.getDriverClassName());
            Connection conn = DriverManager
                    .getConnection(CLICK_HOUSE_CONTAINER.getJdbcUrl(), CLICK_HOUSE_CONTAINER.getUsername(),
                            CLICK_HOUSE_CONTAINER.getPassword());
            Statement stat = conn.createStatement();
            stat.execute("create table test_output1 (\n"
                    + "       id Int32,\n"
                    + "       name Nullable(String),\n"
                    + "       description Nullable(String)\n"
                    + ")\n"
                    + "engine=MergeTree ORDER BY id;");
            stat.close();
            conn.close();
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }
End-to-end tests
Test flink sql mysql cdc to clickHouse
inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.13/src/test/java/org/apache/inlong/sort/tests/Mysql2ClickHouseTest.java