You are right. The product on alibaba cloud is based on an internal branch. There are much discrepancy between them.
*Best Regards,* *Zhenghua Gao* On Fri, Mar 13, 2020 at 1:09 PM wangl...@geekplus.com.cn < wangl...@geekplus.com.cn> wrote: > Thanks, works now. > > Seems the open source version is different from alibaba cloud: > https://www.alibabacloud.com/help/doc-detail/62506.htm > > > ------------------------------ > wangl...@geekplus.com.cn > > *From:* Zhenghua Gao <doc...@gmail.com> > *Date:* 2020-03-13 12:12 > *To:* wangl...@geekplus.com.cn > *CC:* user <user@flink.apache.org> > *Subject:* Re: dimention table join not work under sql-client fink-1.10.0 > We don't support 'PROCTIME()' in a temporal table join. Please use a left > table's proctime field. [1] > > [1] > https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/streaming/joins.html#usage-1 > > *Best Regards,* > *Zhenghua Gao* > > > On Fri, Mar 13, 2020 at 11:57 AM wangl...@geekplus.com.cn < > wangl...@geekplus.com.cn> wrote: > >> >> Kafka source table: >> >> CREATE TABLE out_order ( >> out_order_code VARCHAR, >> intput_date BIGINT, >> owner_code VARCHAR >> ) WITH ( >> 'connector.type' = 'kafka', >> >> MySQL dimention table: >> >> CREATE TABLE dim_owner ( >> owner_code VARCHAR, >> owner_name VARCHAR >> ) WITH ( >> 'connector.type' = 'jdbc', >> >> When i submit the sql: SELECT o.out_order_code, o.input_date, o.owner_code, >> d.owner_name FROM out_order as o >> >> JOIN dim_owner FOR SYSTEM_TIME AS OF PROCTIME() as >> d ON o.owner_code = d.owner_code; >> >> There's error: >> [ERROR] Could not execute SQL statement. Reason: >> org.apache.flink.table.api.TableException: Temporal table join currently >> only supports 'FOR SYSTEM_TIME AS OF' left table's proctime field, doesn't >> support 'PROCTIME()' >> >> Thanks, >> Lei >> >> ------------------------------ >> wangl...@geekplus.com.cn >> >>
