You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Danny Chen (Jira)" <ji...@apache.org> on 2022/08/24 02:23:00 UTC
[jira] [Created] (FLINK-29090) Fix the code gen for ColumnarMapData and ColumnarArrayData
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)