Hi All??
????FlinkSqlParserImpl.FACTORY????Flink DML SQL????????????Join with
Temporal Table????????????????LATERAL????????????????
LEFT JOIN
side_room FOR SYSTEM_TIME AS OF a1.proctime as a2
ON
a1.rowkey_room = a2.rowkey
????????????????
LEFT JOIN LATERAL `side_room` FOR SYSTEM_TIME AS OF `a1`.`proctime`
AS `a2` ON `a1`.`rowkey_room` = `a2`.`rowkey`
??SQL??????Flink SQL??????????????????
Caused by: org.apache.flink.table.api.SqlParserException: SQL parse
failed. Encountered "`side_room`" at line 7, column 19.
Was expecting one of:
"TABLE" ...
"(" ...
????SqlParser.Config????????????
private final SqlParser.Config config = SqlParser.configBuilder()
.setParserFactory(FlinkSqlParserImpl.FACTORY)
.setQuoting(Quoting.BACK_TICK)
.setUnquotedCasing(Casing.UNCHANGED)
.setQuotedCasing(Casing.UNCHANGED)
.setCaseSensitive(true)
.build();
??????????????????????????????????????????????????????????????
