Backporting array_agg from 1.20 to 1.18

2024-10-23 Thread Hanyu (Peter) Zheng via user
Hi Daniele Parmeggiani, I have some ideas regarding the issue. From the exception: java.lang.ClassCastException: class org.apache.flink.types.Row cannot be cast to class org.apache.flink.table.data.RowData This error clearly indicates that the code is trying to cast a Row object to a RowData obje

Re: Backporting array_agg from 1.20 to 1.18

2024-10-23 Thread Hanyu (Peter) Zheng via user
Hi Daniele Parmeggiani, I have some ideas regarding the issue. From the exception: java.lang.ClassCastException: class org.apache.flink.types.Row cannot be cast to class org.apache.flink.table.data.RowData This error clearly indicates that the code is trying to cast a Row object to a RowData obje

https://lists.apache.org/thread/vk4nb2d6n3n35bgjdrj1b0ndbpkxr0qw

2024-10-23 Thread Hanyu (Peter) Zheng via user
https://lists.apache.org/thread/vk4nb2d6n3n35bgjdrj1b0ndbpkxr0qw -- [image: Confluent] Hanyu (Peter) Zheng he/him/his Software Engineer +1 (213) 431-7193 <+1+(213)+431-7193> Follow us: [image: Blog]

RE: https://lists.apache.org/thread/vk4nb2d6n3n35bgjdrj1b0ndbpkxr0qw

2024-10-23 Thread Hanyu (Peter) Zheng via user
I have some idea https://lists.apache.org/thread/vk4nb2d6n3n35bgjdrj1b0ndbpkxr0qw -- [image: Confluent] Hanyu (Peter) Zheng he/him/his Software Engineer +1 (213) 431-7193 <+1+(213)+431-7193> Follow us: [image: Blog]

RE: Backporting array_agg from 1.20 to 1.18

2024-10-23 Thread Hanyu (Peter) Zheng via user
I have some ideas. -- [image: Confluent] Hanyu (Peter) Zheng he/him/his Software Engineer +1 (213) 431-7193 <+1+(213)+431-7193> Follow us: [image: Blog]