Bowen Li created FLINK-15259: -------------------------------- Summary: HiveInspector.toInspectors() should convert Flink constant to Hive constant Key: FLINK-15259 URL: https://issues.apache.org/jira/browse/FLINK-15259 Project: Flink Issue Type: Bug Components: Connectors / Hive Reporter: Bowen Li Assignee: Bowen Li Fix For: 1.10.0, 1.11.0
repro test: {code:java} 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')"); } } {code} seems that currently HiveInspector.toInspectors() didn't convert Flink constant to Hive constant before calling hiveShim.getObjectInspectorForConstant -- This message was sent by Atlassian Jira (v8.3.4#803005)