?????? Flink SQL????????

Mon, 18 May 2020 02:02:28 -0700 

1.10




------------------ ???????? ------------------
??????:&nbsp;"Jark Wu"<[email protected]&gt;;
????????:&nbsp;2020??5??17??(??????) ????11:42
??????:&nbsp;"user-zh"<[email protected]&gt;;

????:&nbsp;Re: Flink SQL????????



?????????????????? bug???????? calcite ???????? ?????????????????? flink??

Best,
Jark

On Thu, 14 May 2020 at 15:30, Senior.Hu <[email protected]&gt; wrote:

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

回复