tartarus created FLINK-27387: -------------------------------- Summary: Support Insert Multi-Table Key: FLINK-27387 URL: https://issues.apache.org/jira/browse/FLINK-27387 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 testInsertMultiTable() { tableEnv.executeSql("create table t1 (id bigint, name string)"); tableEnv.executeSql("create table t2 (id bigint, name string)"); tableEnv.executeSql("create table t3 (id bigint, name string, age int)"); tableEnv.executeSql("from (select id, name, age from t3) t " + "insert overwrite table t1 select id, name where age < 20 " + "insert overwrite table t2 select id, name where age > 20 "); } {code} This is a very common case for batch. -- This message was sent by Atlassian Jira (v8.20.7#820007)