private MySqlExtractNode buildMySQLExtractNode2() {
        List<FieldInfo> fields = Arrays.asList(new FieldInfo("currency", new LongFormatInfo()),
                new FieldInfo("conversion_rate", new DecimalFormatInfo(32, 2)),
                new FieldInfo("currency", new StringFormatInfo()),
                new FieldInfo("update_time", new TimestampFormatInfo(3)),
                new MetaFieldInfo("proc_time", MetaField.PROCESS_TIME));
        Map<String, String> map = new HashMap<>();
        return new MySqlExtractNode("2", "mysql_input", fields, map, "currency",
                Collections.singletonList("currency_rates"), "inlong", "inlong",
                "jdbc:mysql://localhost:3306/inlong");
    }
Test for temporal join for with {@link FlinkSqlParser} with {@link MySqlExtractNode}
inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/parser/MySqlTemporalJoinRelationSqlParseTest.java