[FLINK-18168] Error results when use UDAF with Object Array return type

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.10.2, 1.11.0, 1.12.0
• Component/s: Table SQL / Runtime
• Labels: pull-request-available
• Assignee: Dan Zou
• Reporter: Dan Zou
• Created: 07/Jun/20 06:33
• Updated: 15/Jul/20 08:42
• Resolved: 25/Jun/20 07:27

Description

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.

Issue Links

• links to: GitHub Pull Request #12542