[
https://issues.apache.org/jira/browse/FLINK-29090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Chen updated FLINK-29090:
-------------------------------
Description:
!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]
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}
was:
!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}
> 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
> Priority: Major
> 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]
> 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)
