[FLINK-20587] Support TIMESTAMP WITH LOCAL TIME ZONE type for datagen source

• Type: Improvement
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.11.1, 1.11.2
• Component/s: Table SQL / Ecosystem
• Labels: stale-major
• Assignee: Unassigned
• Reporter: Forward Xu
• Created: 14/Dec/20 06:53
• Updated: Yesterday 10:57

Description

TABLE DDL:

// 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'
);

The DML SQL:

// code placeholder
insert into default_catalog.default_database.print_table select * from default_catalog.default_database.sourceTable;

Exception:

// 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