[FLINK-27387] Support Insert Multi-Table

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.13.1, 1.15.0
• Fix Version/s: 1.16.0
• Component/s: Connectors / Hive
• Labels: pull-request-available
• Assignee: luoyuxia
• Reporter: tartarus
• Created: 25/Apr/22 08:45
• Updated: 30/Jul/22 14:28
• Resolved: 30/Jul/22 14:28

Description

We can reproduce through a UT

Add test case in HiveDialectITCase

@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 ");
} 

This is a very common case for batch.

Issue Links

• links to: GitHub Pull Request #19647