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

Posted to issues@flink.apache.org by "Dian Fu (Jira)" <ji...@apache.org> on 2020/07/15 08:43:00 UTC

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

     [ https://issues.apache.org/jira/browse/FLINK-18168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Dian Fu updated FLINK-18168:
----------------------------
    Fix Version/s:     (was: 1.11.1)
                   1.11.0

> 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
>            Assignee: Zou
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 1.11.0, 1.10.2, 1.12.0
>
>
> 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)