[FLINK-20722] HiveTableSink should copy the record when converting RowData to Row

• Type: Bug
• Status: Closed
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 1.12.2
• Fix Version/s: 1.13.0, 1.14.0, 1.12.3
• Component/s: Connectors / Hive
• Labels: pull-request-available
• Assignee: Rui Li
• Reporter: Rui Li
• Created: 22/Dec/20 13:10
• Updated: 28/Aug/21 11:17
• Resolved: 21/Apr/21 03:13

Description

Add the following test in TableEnvHiveConnectorITCase to reproduce the issue:

	@Test
	public void test() throws Exception {
		TableEnvironment tableEnv = getTableEnvWithHiveCatalog();
		tableEnv.executeSql("create table src1(key string, val string)");
		tableEnv.executeSql("create table src2(key string, val string)");
		tableEnv.executeSql("create table dest(key string, val string)");
		HiveTestUtils.createTextTableInserter(hiveCatalog, "default", "src1")
				.addRow(new Object[]{"1", "val1"})
				.addRow(new Object[]{"2", "val2"})
				.addRow(new Object[]{"3", "val3"})
				.commit();
		HiveTestUtils.createTextTableInserter(hiveCatalog, "default", "src2")
				.addRow(new Object[]{"3", "val4"})
				.addRow(new Object[]{"4", "val4"})
				.commit();
		tableEnv.executeSql("INSERT OVERWRITE dest\n" +
				"SELECT j.*\n" +
				"FROM (SELECT t1.key, p1.val\n" +
				"      FROM src2 t1\n" +
				"      LEFT OUTER JOIN src1 p1\n" +
				"      ON (t1.key = p1.key)\n" +
				"      UNION ALL\n" +
				"      SELECT t2.key, p2.val\n" +
				"      FROM src2 t2\n" +
				"      LEFT OUTER JOIN src1 p2\n" +
				"      ON (t2.key = p2.key)) j").await();
	}

Issue Links

• links to: GitHub Pull Request #14484
• links to: GitHub Pull Request #15696