tartarus created FLINK-27386: -------------------------------- Summary: throw NPE if multi MAPJOIN hint union all Key: FLINK-27386 URL: https://issues.apache.org/jira/browse/FLINK-27386 Project: Flink Issue Type: Sub-task Components: Connectors / Hive Affects Versions: 1.13.1, 1.15.0 Reporter: tartarus
We can reproduce through a UT Add test case in HiveDialectITCase {code:java} @Test public void testHiveMultiMapJoinUnionAll() { tableEnv.executeSql("create table t1 (id bigint, name string)"); tableEnv.executeSql("create table t2 (id bigint, name string)"); tableEnv.executeSql("select /*+ mapjoin(t2) */ t1.id from t1 join t2 on t1.id = t2.id union all select /*+ mapjoin(t2) */ t1.id from t1 join t2 on t1.name = t2.name"); } {code} -- This message was sent by Atlassian Jira (v8.20.7#820007)