[FLINK-24862] The user-defined hive udaf/udtf cannot be used normally in hive dialect - ASF JIRA

XML

Word

Printable

JSON

Details

Type: Bug
Status: Closed
Priority: Major
Resolution: Fixed
Affects Version/s: 1.11.0, 1.12.0, 1.13.0, 1.14.0
Fix Version/s: 1.15.0, 1.14.6
Component/s: Connectors / Hive
Labels:
- pull-request-available

Description

When hive udaf/udtf is used, a validate exception is thrown ，i added a unit test in HiveDialectITCase to reproduce this question:

@Test
public void testTemporaryFunctionUDAF() throws Exception {
    // create temp function
    tableEnv.executeSql(
            String.format(
                    "create temporary function temp_count as '%s'",
                    GenericUDAFCount.class.getName()));
    String[] functions = tableEnv.listUserDefinedFunctions();
    assertArrayEquals(new String[] {"temp_count"}, functions);
    // call the function
    tableEnv.executeSql("create table src(x int)");
    tableEnv.executeSql("insert into src values (1),(-1)").await();
    assertEquals(
            "[+I[2]]",
            queryResult(tableEnv.sqlQuery("select temp_count(x) from src")).toString());
    // switch DB and the temp function can still be used
    tableEnv.executeSql("create database db1");
    tableEnv.useDatabase("db1");
    assertEquals(
            "[+I[2]]",
            queryResult(tableEnv.sqlQuery("select temp_count(x) from `default`.src"))
                    .toString());
    // drop the function
    tableEnv.executeSql("drop temporary function temp_count");
    functions = tableEnv.listUserDefinedFunctions();
    assertEquals(0, functions.length);
    tableEnv.executeSql("drop temporary function if exists foo");
}