Backporting array_agg from 1.20 to 1.18

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

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

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

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

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]

java.lang.SecurityException: setContextClassLoader

Hi Flink Community, I'm in the process of upgrading a Flink application to 1.17.1, and I'm running into the following exception in my integration test: java.lang.SecurityException: setContextClassLoader at java.base/java.util.concurrent.ForkJoinWorkerThread$InnocuousForkJoinWorkerThread.

??????[ANNOUNCE] Apache Flink 2.0 Preview released

How to import the source code(from github) to Intelligent Idea,seems that a project descriptor is missing. --  -- ??: "Xintong Son

[ANNOUNCE] Apache Flink 2.0 Preview released

The Apache Flink community is very happy to announce the release of Apache Flink 2.0 Preview. Apache Flink® is an open-source unified stream and batch data processing framework for distributed, high-performing, always-available, and accurate data applications. This release is a preview of the upc

Re: Re:Backpressure causing operators to stop ingestion completely

Hi Jake, Thanks for the suggestion. I'm actually using PyFlink and it seems that the flame graph can only account for Java methods. Is there any other methods to debug this? I was curious about the network buffers tuning. Given the situation that there's a surge of input data at times while oth