You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn> on 2020/03/13 03:56:51 UTC
dimention table join not work under sql-client fink-1.10.0
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
wanglei2@geekplus.com.cn
Re: Re: dimention table join not work under sql-client fink-1.10.0
Posted by Zhenghua Gao <do...@gmail.com>.
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 wanglei2@geekplus.com.cn <
wanglei2@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
>
>
> ------------------------------
> wanglei2@geekplus.com.cn
>
> *From:* Zhenghua Gao <do...@gmail.com>
> *Date:* 2020-03-13 12:12
> *To:* wanglei2@geekplus.com.cn
> *CC:* user <us...@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 wanglei2@geekplus.com.cn <
> wanglei2@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
>>
>> ------------------------------
>> wanglei2@geekplus.com.cn
>>
>>
Re: Re: dimention table join not work under sql-client fink-1.10.0
Posted by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn>.
Thanks, works now.
Seems the open source version is different from alibaba cloud:
https://www.alibabacloud.com/help/doc-detail/62506.htm
wanglei2@geekplus.com.cn
From: Zhenghua Gao
Date: 2020-03-13 12:12
To: wanglei2@geekplus.com.cn
CC: user
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 wanglei2@geekplus.com.cn <wa...@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
wanglei2@geekplus.com.cn
Re: dimention table join not work under sql-client fink-1.10.0
Posted by Zhenghua Gao <do...@gmail.com>.
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 wanglei2@geekplus.com.cn <
wanglei2@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
>
> ------------------------------
> wanglei2@geekplus.com.cn
>
>