??????Flink??table-api??????.

Sun, 04 Oct 2020 02:56:12 -0700 

???????????????????
???????????????????????????




------------------ ???????? ------------------
??????:                                                                         
                                               "user-zh"                        
                                                            
<153488...@qq.com&gt;;
????????:&nbsp;2020??10??4??(??????) ????5:09
??????:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

????:&nbsp;Flink??table-api??????.



Hi,all:


Table api??sql????????join????????????"."???
?????????????? ????
Exception in thread "main" org.apache.flink.table.api.SqlParserException: SQL 
parse failed. Encountered "." at line 1, column 36.
Was expecting one of:
&amp;nbsp; &amp;nbsp; <EOF&amp;gt;&amp;nbsp;
&amp;nbsp; &amp;nbsp; "EXCEPT" ...
&amp;nbsp; &amp;nbsp; "FETCH" ...
&amp;nbsp; &amp;nbsp; "FROM" ...
&amp;nbsp; &amp;nbsp; "INTERSECT" ...
&amp;nbsp; &amp;nbsp; "LIMIT" ...
&amp;nbsp; &amp;nbsp; "OFFSET" ...
&amp;nbsp; &amp;nbsp; "ORDER" ...
&amp;nbsp; &amp;nbsp; "MINUS" ...
&amp;nbsp; &amp;nbsp; "UNION" ...
&amp;nbsp; &amp;nbsp; "," ...



Table result = tEnv.sqlQuery("select *&nbsp; from&nbsp; OrderA join OrderB on 
OrderA.user=OrderB.user");

回复