You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Zou (Jira)" <ji...@apache.org> on 2020/06/07 06:34:00 UTC

[jira] [Created] (FLINK-18168) Error results when use UDAF with Object Array return type

Zou created FLINK-18168:
---------------------------

             Summary: Error results when use UDAF with Object Array return type
                 Key: FLINK-18168
                 URL: https://issues.apache.org/jira/browse/FLINK-18168
             Project: Flink
          Issue Type: Bug
          Components: Table SQL / Runtime
            Reporter: Zou


I get error results when I use an UDAF with Object Array return type (e.g. Row[]). I find that the problem is we reuse 'reuseArray' as the return value of ObjectArrayConverter.toBinaryArray(). It leads to 'prevAggValue' and 'newAggValue' in GroupAggFunction.processElement() contains exactly the same BinaryArray, so 'equaliser.equalsWithoutHeader(prevAggValue, newAggValue)' is always true.



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