[
https://issues.apache.org/jira/browse/FLINK-26361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-26361:
-----------------------------
Description:
With hive dialect, can be reproduced using such code:
{code:java}
tableEnv.executeSql("CREATE TABLE src (key string, value string)");
tableEnv.executeSql("create view cv1 as \n"
+ "select * \n"
+ "from src b where exists\n"
+ " (select a.key \n"
+ " from src a \n"
+ " where b.value = a.value )");
List<Row> results =
CollectionUtil.iteratorToList(tableEnv.executeSql("select *
from src where src"
+ ".key in (select key from cv1)").collect());
{code}
The plan for such sql is :
{code:java}
LogicalSink(table=[*anonymous_collect$1*], fields=[key, value])
LogicalProject(key=[$0], value=[$1])
LogicalFilter(condition=[IN($0, {
LogicalProject(key=[$0])
LogicalProject(key=[$0], value=[$1])
LogicalFilter(condition=[EXISTS({
LogicalProject(key=[$0])
LogicalFilter(condition=[=($cor0.value, $1)])
LogicalTableScan(table=[[test-catalog, default, src]])
})])
LogicalTableScan(table=[[test-catalog, default, src]])
})])
LogicalTableScan(table=[[test-catalog, default, src]])
{code}
The node LogicalFilter(condition=[=($cor0.value, $1)]) contains `$cor0`, but
miss variablesSet. To fix it, we should pass variablesSet when create
LogicalFilter.
> "Unexpected correlate variable $cor0" when using hive dialect to write a
> subquery
> ---------------------------------------------------------------------------------
>
> Key: FLINK-26361
> URL: https://issues.apache.org/jira/browse/FLINK-26361
> Project: Flink
> Issue Type: Sub-task
> Reporter: luoyuxia
> Priority: Major
>
> With hive dialect, can be reproduced using such code:
> {code:java}
> tableEnv.executeSql("CREATE TABLE src (key string, value string)");
> tableEnv.executeSql("create view cv1 as \n"
> + "select * \n"
> + "from src b where exists\n"
> + " (select a.key \n"
> + " from src a \n"
> + " where b.value = a.value )");
> List<Row> results =
> CollectionUtil.iteratorToList(tableEnv.executeSql("select *
> from src where src"
> + ".key in (select key from cv1)").collect());
> {code}
> The plan for such sql is :
> {code:java}
> LogicalSink(table=[*anonymous_collect$1*], fields=[key, value])
> LogicalProject(key=[$0], value=[$1])
> LogicalFilter(condition=[IN($0, {
> LogicalProject(key=[$0])
> LogicalProject(key=[$0], value=[$1])
> LogicalFilter(condition=[EXISTS({
> LogicalProject(key=[$0])
> LogicalFilter(condition=[=($cor0.value, $1)])
> LogicalTableScan(table=[[test-catalog, default, src]])
> })])
> LogicalTableScan(table=[[test-catalog, default, src]])
> })])
> LogicalTableScan(table=[[test-catalog, default, src]])
> {code}
> The node LogicalFilter(condition=[=($cor0.value, $1)]) contains `$cor0`, but
> miss variablesSet. To fix it, we should pass variablesSet when create
> LogicalFilter.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
