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)
