private OceanBaseLoadNode buildMysqlLoadNode() {
        final List<FieldInfo> fields = Arrays.asList(
                new FieldInfo("id", new IntFormatInfo()),
                new FieldInfo("user_name", new StringFormatInfo()),
                new FieldInfo("phone", new StringFormatInfo()));

        final List<FieldRelation> fieldRelations = Arrays
                .asList(new FieldRelation(new FieldInfo("id", new IntFormatInfo()),
                        new FieldInfo("id", new IntFormatInfo())),
                        new FieldRelation(new FieldInfo("user_name", new StringFormatInfo()),
                                new FieldInfo("user_name", new StringFormatInfo())),
                        new FieldRelation(new FieldInfo("phone", new IntFormatInfo()),
                                new FieldInfo("phone", new IntFormatInfo())));

        Map<String, String> properties = new HashMap<>();
        properties.put("dirty.side-output.connector", "log");
        properties.put("dirty.ignore", "true");
        properties.put("dirty.side-output.enable", "true");
        properties.put("dirty.side-output.format", "csv");
        properties.put("dirty.side-output.labels",
                "SYSTEM_TIME=${SYSTEM_TIME}&DIRTY_TYPE=${DIRTY_TYPE}&database=inlong&table=inlong_oceanbase");
        return new OceanBaseLoadNode("2", "mysql_output", fields, fieldRelations, null,
                null, null, properties, "jdbc:mysql://localhost:2883/test",
                "root", "123456", "t_ds_user", "id");
    }
Test mysql cdc for {@link OceanBaseLoadNode}
inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/parser/MySqlExtractNodeToOceanBaseLoadNodeTest.java