Jark Wu created FLINK-27369:
-------------------------------
Summary: COALESCE('1', CAST(NULL as varchar)) throws expression
type mismatch
Key: FLINK-27369
URL: https://issues.apache.org/jira/browse/FLINK-27369
Project: Flink
Issue Type: Bug
Components: Table SQL / Planner
Affects Versions: 1.15.0
Reporter: Jark Wu
Fix For: 1.15.0
{code}
Flink SQL> SELECT
> COALESCE('1', cast(NULL as varchar)),
> COALESCE('4', cast(NULL as varchar), cast(NULL as varchar), cast(NULL as
> varchar));
Exception in thread "main" org.apache.flink.table.client.SqlClientException:
Unexpected exception. This is a bug. Please consider filing an issue.
at
org.apache.flink.table.client.SqlClient.startClient(SqlClient.java:201)
at org.apache.flink.table.client.SqlClient.main(SqlClient.java:161)
Caused by: java.lang.AssertionError: Cannot add expression of different type to
set:
set type is RecordType(VARCHAR(2147483647) CHARACTER SET "UTF-16LE" NOT NULL
EXPR$0, VARCHAR(2147483647) CHARACTER SET "UTF-16LE" NOT NULL EXPR$1) NOT NULL
expression type is RecordType(CHAR(1) CHARACTER SET "UTF-16LE" NOT NULL EXPR$0,
CHAR(1) CHARACTER SET "UTF-16LE" NOT NULL EXPR$1) NOT NULL
set is rel#910:LogicalProject.NONE.any.None:
0.[NONE].[NONE](input=HepRelVertex#909,exprs=[COALESCE(_UTF-16LE'1',
null:VARCHAR(2147483647) CHARACTER SET "UTF-16LE"), COALESCE(_UTF-16LE'4',
null:VARCHAR(2147483647) CHARACTER SET "UTF-16LE", null:VARCHAR(2147483647)
CHARACTER SET "UTF-16LE", null:VARCHAR(2147483647) CHARACTER SET "UTF-16LE")])
expression is LogicalProject(EXPR$0=[_UTF-16LE'1'], EXPR$1=[_UTF-16LE'4'])
LogicalValues(tuples=[[{ 0 }]])
{code}
--
This message was sent by Atlassian Jira
(v8.20.7#820007)