[jira] [Created] (FLINK-29090) Fix the code gen for ColumnarMapData and ColumnarArrayData

[Danny Chen (Jira)]

Danny Chen created FLINK-29090:
----------------------------------

             Summary: Fix the code gen for ColumnarMapData and ColumnarArrayData
                 Key: FLINK-29090
                 URL: https://issues.apache.org/jira/browse/FLINK-29090
             Project: Flink
          Issue Type: Bug
          Components: Table SQL / Runtime
    Affects Versions: 1.16.0
            Reporter: Danny Chen
             Fix For: 1.16.0
         Attachments: image-2022-08-24-10-15-11-824.png

!image-2022-08-24-10-15-11-824.png|width=589,height=284!

Currently, the code generation for {{MapData}} assumes that it is the 
{{{}GenericMapData{}}}, but the new introduced {{ColumnarMapData}} and 
{{ColumnarArrayData}} can not be casted to {{{}GenericMapData{}}}.

{{ColumnarMapData}} and {{ColumnarArrayData}} are introduced in
FLINK-24614 
[https://github.com/apache/flink/commit/5c731a37e1a8f71f9c9e813f6c741a1e203fa1a3]
introduces,

How to reproduce:
{code:sql}
create table parquet_source (
  f_map map<varchar(20), int>
) with (
  'connector' = 'filesystem',
  'format' = 'parquet'
);

select f_map['k1'] from table parquet_source;

{code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)