[jira] [Created] (FLINK-14273) when User-Defined Aggregate Functions(UDAF) parameters are inconsistent with the definition, the error reporting is confusing

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

hailong wang created FLINK-14273:
------------------------------------

             Summary: when User-Defined Aggregate Functions(UDAF) parameters are inconsistent with the definition, the error reporting is confusing
                 Key: FLINK-14273
                 URL: https://issues.apache.org/jira/browse/FLINK-14273
             Project: Flink
          Issue Type: Improvement
          Components: Table SQL / Runtime
    Affects Versions: 1.9.0
            Reporter: hailong wang
             Fix For: 1.10.0


When UDAF parameters are inconsistent with the definition of accumulate method, all arguments to the accumulate method are listed in the error. But the first argument of accumulate is accumulator, users don't have to care when using SQL.

For example:
{code:java}
INSERT INTO Orders SELECT name, USERUDAF(id, name) FROM Orders GROUP BY TUMBLE(rowTime, interval '10' second ), id, name
{code}
USERUDAF is a User-Defined Aggregate Functions, and accumulate is defined as follow:
{code:java}
public void accumulate(Long acc, String a) {……}
{code}
At present, error is as follows:
{code:java}
Caused by: org.apache.flink.table.api.ValidationException: Given parameters of function do not match any signature. 
Actual: (java.lang.Integer, java.lang.String) 
Expected: (java.lang.Integer, java.lang.String)
{code}
This error will mislead users, and the expected errors are as follows :
{code:java}
Caused by: org.apache.flink.table.api.ValidationException: Given parameters of function do not match any signature. 
Actual: (java.lang.Integer, java.lang.String) 
Expected: (java.lang.String){code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)