Jark Wu created FLINK-15381:
-------------------------------
Summary: INSERT INTO VALUES statement fails if a cast project is
applied
Key: FLINK-15381
URL: https://issues.apache.org/jira/browse/FLINK-15381
Project: Flink
Issue Type: Bug
Components: Table SQL / Planner
Reporter: Jark Wu
Assignee: godfrey he
Fix For: 1.10.0
The following query will fail:
{code:scala}
@Test
def test(): Unit = {
val sinkDDL =
"""
|create table t2(
| a int,
| b string
|) with (
| 'connector' = 'COLLECTION'
|)
""".stripMargin
val query =
"""
|insert into t2 select cast(a as int), cast(b as varchar) from (values
(3, 'c')) T(a,b)
""".stripMargin
tableEnv.sqlUpdate(sinkDDL)
tableEnv.sqlUpdate(query)
execJob("testJob")
}
{code}
exception:
{code}
org.apache.flink.table.api.TableException: Cannot generate a valid execution
plan for the given query:
LogicalSink(name=[`default_catalog`.`default_database`.`t2`], fields=[a, b])
+- LogicalProject(EXPR$0=[$0], EXPR$1=[CAST($1):VARCHAR(2147483647) CHARACTER
SET "UTF-16LE" NOT NULL])
+- LogicalValues(type=[RecordType(INTEGER a, CHAR(1) b)], tuples=[[{ 3,
_UTF-16LE'c' }]])
This exception indicates that the query uses an unsupported SQL feature.
Please check the documentation for the set of currently supported SQL features.
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
