[jira] [Created] (FLINK-27175) Fail to call Hive UDAF when the UDAF is with only one parameter with array type

["luoyuxia (Jira)" <ji...@apache.org>]

luoyuxia created FLINK-27175:
--------------------------------

             Summary: Fail to call Hive UDAF when the UDAF is with only one parameter with array type
                 Key: FLINK-27175
                 URL: https://issues.apache.org/jira/browse/FLINK-27175
             Project: Flink
          Issue Type: Sub-task
            Reporter: luoyuxia


When try to call Hive's collect_list function, it'll throw the following exception:

 
{code:java}
Caused by: java.lang.ClassCastException: java.lang.Integer cannot be cast to [Ljava.lang.Object;
    at org.apache.flink.table.functions.hive.conversion.HiveInspectors.lambda$getConversion$7f882244$1(HiveInspectors.java:201)
    at org.apache.flink.table.functions.hive.HiveGenericUDAF.accumulate(HiveGenericUDAF.java:185)
    at LocalNoGroupingAggregateWithoutKeys$39.processElement(Unknown Source) {code}
The reason is when the parameter is a single array, Flink calls udf.accumulate(AggregationBuffer, Array[Double]), at this point java's var-args will cast Array[Double] to Array[Object]and let it be Object... args.
{code:java}
public void accumulate(GenericUDAFEvaluator.AggregationBuffer acc, Object... inputs) {code}
Then it will consider the elements in the array as parameters.

 

The exception will also happen for other similar Hive UDAF.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)