[jira] [Created] (FLINK-13378) Wrong comment in SingleValueAggFunction.accumulateExpressions()

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-13378) Wrong comment in SingleValueAggFunction.accumulateExpressions()

Shang Yuanchun (Jira)
Louis Xu created FLINK-13378:
--------------------------------

             Summary: Wrong comment in SingleValueAggFunction.accumulateExpressions()
                 Key: FLINK-13378
                 URL: https://issues.apache.org/jira/browse/FLINK-13378
             Project: Flink
          Issue Type: Bug
          Components: Table SQL / Planner
    Affects Versions: 1.9.0, 1.10.0
            Reporter: Louis Xu
             Fix For: 1.10.0


1.The comment in the method is "value = count == 0 ? exception : operand(0)", but actually it need to be "value = count > 0 ? exception : operand(0)" according to the code and logic.

2.And the "throwException" expression's parameter msg is never used. And if we only think about "throwException" expression, the param "type" is the return type of agg function or msg's type? I don't known the definition of "throwException" expression, but I think this might be some problem.

3.If we need use param msg, the expression is call(THROW_EXCEPTION, literal(msg, type)) or 

call(THROW_EXCEPTION, literal(msg), typeLiteral(type)).



--
This message was sent by Atlassian JIRA
(v7.6.14#76016)