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

---

[hidden email] 

[Zhenghua Gao]

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

On Fri, Mar 13, 2020 at 11:57 AM [hidden email] <[hidden email]> 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

---

[hidden email] 

Thanks, works now. 

Seems the open source version is  different from alibaba cloud: 

https://www.alibabacloud.com/help/doc-detail/62506.htm

---

[hidden email] 

From: [hidden email]

Date: 2020-03-13 12:12

To: [hidden email]

CC: [hidden email]

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

On Fri, Mar 13, 2020 at 11:57 AM [hidden email] <[hidden email]> 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

---

[hidden email] 

[Zhenghua Gao]

You are right. 

The product on alibaba cloud is based on an internal branch.

There are much discrepancy between them.

Best Regards,

On Fri, Mar 13, 2020 at 1:09 PM [hidden email] <[hidden email]> wrote:

Thanks, works now. 

Seems the open source version is  different from alibaba cloud: 

https://www.alibabacloud.com/help/doc-detail/62506.htm

---

[hidden email] 

From: [hidden email]

Date: 2020-03-13 12:12

To: [hidden email]

CC: [hidden email]

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 [hidden email] <[hidden email]> 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

---

[hidden email]