[FLINK-24204] Failed to insert nested types using value construction functions

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Affects Version/s: 1.13.2
• Component/s: Table SQL / API
• Assignee: Unassigned
• Reporter: Jark Wu
• Created: 08/Sep/21 04:35
• Updated: 08/Sep/21 07:09
• Resolved: 08/Sep/21 07:09

Description

Flink SQL> CREATE TABLE nested_type (
>     row_type ROW<id BIGINT, data STRING>,
>     map_type MAP<STRING, BIGINT>,
>     array_type ARRAY<BIGINT>
> ) WITH ('connector'='print');
[INFO] Execute statement succeed.

Flink SQL> INSERT INTO nested_type VALUES ((1, 'data'), MAP['key', 1], ARRAY[1,2,3])
> ;
[INFO] Submitting SQL update statement to the cluster...
[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.table.planner.codegen.CodeGenException: Unsupported cast from 'MAP<CHAR(3) NOT NULL, INT NOT NULL> NOT NULL' to 'MAP<STRING, BIGINT>'.

The query works if we change the sink table definition to :

CREATE TABLE nested_type (
    row_type ROW<id BIGINT, data STRING>,
    map_type MAP<STRING, INT>,
    array_type ARRAY<INT>
) WITH (
     'connector'='print'
);

Therefore, I think the root cause of this problem is Flink SQL doesn't support cast for nested types when code generation.

Issue Links

• is duplicated by: FLINK-17321 Support for casting collection types.