private PostgresLoadNode buildPostgresLoadNode() {
        Map<String, String> properties = new LinkedHashMap<>();
        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=test&table=test2");
        return new PostgresLoadNode("2", "postgres_output", Arrays.asList(new FieldInfo("name",
                new StringFormatInfo()), new FieldInfo("age", new IntFormatInfo())),
                Arrays.asList(new FieldRelation(new FieldInfo("name", new StringFormatInfo()),
                        new FieldInfo("name", new StringFormatInfo())),
                        new FieldRelation(new FieldInfo("age", new IntFormatInfo()),
                                new FieldInfo("age", new IntFormatInfo()))),
                null, null, 1, properties,
                "jdbc:postgresql://localhost:5432/postgres",
                "postgres",
                "inlong",
                "public.user",
                "name,age");
    }
build postgres load node

@return postgres load node
inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/parser/PostgresLoadNodeFlinkSqlParseTest.java