[
https://issues.apache.org/jira/browse/FLINK-31375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jeff-zou updated FLINK-31375:
-----------------------------
Description:
the values of map<string,string> are truncated by the CASE WHEN function.
{code:java}
// sql
create table test (a map<varchar, string>) with ('connector'='print');
insert into test select * from (values(case when true then
map['test','123456789'] else map ['msg_code','0', 'msg_reason', 'abc']
end));{code}
the result:
{code:java}
+I[{test=123}] {code}
We hope the value of result is '123456789', but I get '123' .
was:
the values of map<string,string> are truncated by the CASE WHEN function.
{code:java}
// sql
create table test (a map<varchar, string>) with ('connector'='print');
insert into test select * from (values(case when true then
map['test','123456789'] else map ['msg_code','0', 'msg_reason', 'abc']
end));{code}
the result:
{code:java}
+I[{test=123}] {code}
We hope the value of result is '123456789', but I get '123'.
> the values of map<string,string> are truncated by the CASE WHEN function.
> -------------------------------------------------------------------------
>
> Key: FLINK-31375
> URL: https://issues.apache.org/jira/browse/FLINK-31375
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / API
> Affects Versions: 1.15.1
> Reporter: jeff-zou
> Priority: Major
>
> the values of map<string,string> are truncated by the CASE WHEN function.
> {code:java}
> // sql
> create table test (a map<varchar, string>) with ('connector'='print');
> insert into test select * from (values(case when true then
> map['test','123456789'] else map ['msg_code','0', 'msg_reason', 'abc']
> end));{code}
> the result:
> {code:java}
> +I[{test=123}] {code}
> We hope the value of result is '123456789', but I get '123' .
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
