A bug in upsert Kafka 3.3.0 & Flink 1.20?

Hello 👋 We're trying out the new 1.20 version of Flink and the 3.3.0 Kafka upsert connector with SQL and we're hitting some problems. We've been using the 3.1.0 version with Flink 1.18 so far, and it's been working properly for us. When upgrading one of our jobs, without changing the SQL code, w

Re: Backporting array_agg from 1.20 to 1.18

nctions/udfs/#aggregate-functions> > [2] > <https://github.com/apache/flink/blob/28ae3ae65d13b98dc28b919ef75c14780c512618/flink- > table/flink-table- > runtime/src/main/java/org/apache/flink/table/runtime/functions/aggregate/ArrayAggFunction.java> > > On 2024/10/24 08:34:32 Daniele Parmeggiani wrote: > >

Re: Backporting array_agg from 1.20 to 1.18

ion     as 'eu.spaziodati.cp.flink.funcs.ArrayAggFunction'     using jar ' ``` Then I use it like this: ```sql select `...`, ArrayAggFunction(row(...)) ``` So the fact that a Row is being passed into the function does not surprise me, but I don't get how RowData comes into play. Daniele On October 24, 2

Backporting array_agg from 1.20 to 1.18

Hello 👋  At my company we have a Flink SQL job that necessitates the `array_agg` function that was introduced in version 1.20 (this is the only documentation I could find: ).