[jira] [Updated] (FLINK-38720) Nested nullability might lead to class cast RexCall cannot be cast to class RexFieldAccess

[Sergey Nuyanzin (Jira)]

     [ 
https://issues.apache.org/jira/browse/FLINK-38720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Sergey Nuyanzin updated FLINK-38720:
------------------------------------
    Description: 
for example

{code:scala}
util.tableEnv
      .executeSql(
        "CREATE TABLE `testcat.db.tb1.v1` (\n"
          + "  `field0` ROW<`nested` STRING NOT NULL>\n"
          + ") WITH (\n"
          + " 'connector' = 'values',\n"
          + " 'bounded' = 'true'\n"
          + ")")

    util.tableEnv
      .executeSql(
        "CREATE TABLE `testcat.db.tb2.v1` (\n"
          + "  `field0` ROW< `nested0` ROW< `nested1` ROW<`nested2` 
ROW<`nested3` STRING NOT NULL>>>>\n"
          + ") WITH (\n"
          + " 'connector' = 'values',\n"
          + " 'bounded' = 'true'\n"
          + ")")

    util.verifyExecPlan(
      " SELECT \n"
        + "  1\n"
        + "FROM `testcat.db.tb2.v1` t2\n"
        + "WHERE NOT EXISTS (\n"
        + "    SELECT 1\n"
        + "    FROM `testcat.db.tb1.v1` t\n"
        + "    WHERE `t`.`field0`.`nested` = 
`t2`.`field0`.`nested0`.`nested2`.`nested3`\n"
        + ")")
{code}

> Nested nullability might lead to class cast RexCall cannot be cast to class 
> RexFieldAccess
> ------------------------------------------------------------------------------------------
>
>                 Key: FLINK-38720
>                 URL: https://issues.apache.org/jira/browse/FLINK-38720
>             Project: Flink
>          Issue Type: Bug
>          Components: Table SQL / Planner
>            Reporter: Sergey Nuyanzin
>            Assignee: Sergey Nuyanzin
>            Priority: Major
>
> for example
> {code:scala}
> util.tableEnv
>       .executeSql(
>         "CREATE TABLE `testcat.db.tb1.v1` (\n"
>           + "  `field0` ROW<`nested` STRING NOT NULL>\n"
>           + ") WITH (\n"
>           + " 'connector' = 'values',\n"
>           + " 'bounded' = 'true'\n"
>           + ")")
>     util.tableEnv
>       .executeSql(
>         "CREATE TABLE `testcat.db.tb2.v1` (\n"
>           + "  `field0` ROW< `nested0` ROW< `nested1` ROW<`nested2` 
> ROW<`nested3` STRING NOT NULL>>>>\n"
>           + ") WITH (\n"
>           + " 'connector' = 'values',\n"
>           + " 'bounded' = 'true'\n"
>           + ")")
>     util.verifyExecPlan(
>       " SELECT \n"
>         + "  1\n"
>         + "FROM `testcat.db.tb2.v1` t2\n"
>         + "WHERE NOT EXISTS (\n"
>         + "    SELECT 1\n"
>         + "    FROM `testcat.db.tb1.v1` t\n"
>         + "    WHERE `t`.`field0`.`nested` = 
> `t2`.`field0`.`nested0`.`nested2`.`nested3`\n"
>         + ")")
> {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)