[jira] [Updated] (FLINK-20587) Support TIMESTAMP WITH LOCAL TIME ZONE type for datagen source

["Jark Wu (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-20587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jark Wu updated FLINK-20587:
----------------------------
    Summary: Support TIMESTAMP WITH LOCAL TIME ZONE type for datagen source  (was: INSERT INTO  TIMESTAMP WITH LOCAL TIME ZONE VALUES, THROW Unsupported type)

> Support TIMESTAMP WITH LOCAL TIME ZONE type for datagen source
> --------------------------------------------------------------
>
>                 Key: FLINK-20587
>                 URL: https://issues.apache.org/jira/browse/FLINK-20587
>             Project: Flink
>          Issue Type: Improvement
>          Components: Table SQL / Ecosystem
>    Affects Versions: 1.11.1, 1.11.2
>            Reporter: Forward Xu
>            Priority: Major
>
> TABLE DDL:
> {code:java}
> // code placeholder
> CREATE TABLE sourceTable (
>  userid int,
>  f_random_str STRING,
>  order_time TIMESTAMP(3) WITH LOCAL TIME ZONE
> ) WITH (
>  'connector' = 'datagen',
>  'rows-per-second'='100',
>  'fields.userid.kind'='random',
>  'fields.userid.min'='1',
>  'fields.userid.max'='100',
> 'fields.f_random_str.length'='10'
> );
> CREATE TABLE print_table (
>  userid int,
>  f_random_str STRING,
>  order_time TIMESTAMP(3) WITH LOCAL TIME ZONE
> ) WITH (
>  'connector' = 'print'
> );{code}
> The DML SQL:
> {code:java}
> // code placeholder
> insert into default_catalog.default_database.print_table select * from default_catalog.default_database.sourceTable;{code}
> *Exception:*
> {code:java}
> // code placeholder
> Flink SQL> insert into default_catalog.default_database.print_table select * from default_catalog.default_database.sourceTable;
> [ERROR] Could not execute SQL statement. Reason:
> org.apache.flink.table.api.ValidationException: Unsupported type: TIMESTAMP(3) WITH LOCAL TIME ZONE
> {code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)