Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-18168

Error results when use UDAF with Object Array return type

    XMLWordPrintableJSON

    Details

      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.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                FrankZou Zou
                Reporter:
                FrankZou Zou
              • Votes:
                0 Vote for this issue
                Watchers:
                4 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: