[FLINK-16732] Failed to call Hive UDF with constant return value

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.10.0
• Fix Version/s: 1.10.1
• Component/s: Connectors / Hive
• Labels: pull-request-available
• Assignee: Rui Li
• Reporter: Rui Li
• Created: 24/Mar/20 03:02
• Updated: 24/Mar/20 12:45
• Resolved: 24/Mar/20 12:45

Description

The following test fails:

	@Test
	public void test() throws Exception {
		tableEnv.unloadModule("core");
		tableEnv.loadModule("hive", new HiveModule());
		tableEnv.loadModule("core", CoreModule.INSTANCE);
		System.out.println(TableUtils.collectToList(tableEnv.sqlQuery("select str_to_map('a:1,b:2,c:3',',',':')")));
	}

With exception:

Caused by: java.lang.ClassCastException: java.lang.String cannot be cast to org.apache.hadoop.io.Text
	at org.apache.hadoop.hive.serde2.objectinspector.primitive.WritableStringObjectInspector.getPrimitiveJavaObject(WritableStringObjectInspector.java:46)
	at org.apache.hadoop.hive.serde2.objectinspector.primitive.WritableStringObjectInspector.getPrimitiveJavaObject(WritableStringObjectInspector.java:26)
	at org.apache.flink.table.functions.hive.conversion.HiveInspectors.toFlinkObject(HiveInspectors.java:277)
	at org.apache.flink.table.functions.hive.conversion.HiveInspectors.toFlinkObject(HiveInspectors.java:319)
	at org.apache.flink.table.functions.hive.HiveGenericUDF.evalInternal(HiveGenericUDF.java:86)
	at org.apache.flink.table.functions.hive.HiveScalarFunction.eval(HiveScalarFunction.java:100)
......

Issue Links

• links to: GitHub Pull Request #11494