[FLINK-15259] HiveInspector.toInspectors() should convert Flink constant to Hive constant

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 1.9.0, 1.10.0
• Fix Version/s: 1.9.2, 1.10.0
• Component/s: Connectors / Hive
• Labels: pull-request-available
• Assignee: Rui Li
• Reporter: Bowen Li
• Created: 13/Dec/19 22:44
• Updated: 06/Jan/20 16:07
• Resolved: 02/Jan/20 04:47

Description

repro test:

public class HiveModuleITCase {
	@Test
	public void test() {
		TableEnvironment tEnv = HiveTestUtils.createTableEnvWithBlinkPlannerBatchMode();

		tEnv.unloadModule("core");
		tEnv.loadModule("hive", new HiveModule("2.3.4"));

		tEnv.sqlQuery("select concat('an', 'bn')");
	}
}

seems that currently HiveInspector.toInspectors() didn't convert Flink constant to Hive constant before calling hiveShim.getObjectInspectorForConstant

I don't think it's a blocker

Issue Links

• links to: GitHub Pull Request #10625
• links to: GitHub Pull Request #10747