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: 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]

[jira] [Created] (FLINK-36595) Supported Flink version for connector documentation does not get matched for 1.20

Aleksandr Pilipenko created FLINK-36595: --- Summary: Supported Flink version for connector documentation does not get matched for 1.20 Key: FLINK-36595 URL: https://issues.apache.org/jira/browse/FLINK-36595

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: Backporting array_agg from 1.20 to 1.18

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

-- [image: Confluent] Hanyu (Peter) Zheng he/him/his Software Engineer +1 (213) 431-7193 <+1+(213)+431-7193> Follow us: [image: Blog] [image: Tw

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.10.0, release candidate #1

+1 (binding) - Verified Helm repo works as expected, points to correct image tag, build, version - Verified basic examples + checked operator logs everything looks as expected - Verified hashes, signatures and source release contains no binaries - Ran built-in tests, built jars + docker image from

Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF)

Hi Timo, Thank you for the answers. I have a few clarifications inlined. On Mon, Oct 14, 2024 at 8:07 AM Timo Walther wrote: > 3. Change of interfaces for multiple output tables > Currently, I think using a STATEMENT SET should be enough for side > output semantics. I have added an example in

[jira] [Created] (FLINK-36594) HiveCatalog should set HiveConf.hiveSiteLocation back

slankka created FLINK-36594: --- Summary: HiveCatalog should set HiveConf.hiveSiteLocation back Key: FLINK-36594 URL: https://issues.apache.org/jira/browse/FLINK-36594 Project: Flink Issue Type: Bug

Re: [DISCUSS] FLIP-440: User-defined SQL operators / ProcessTableFunction (PTF)

Hi everyone, thank you, Timo, for this proposal. ProccessTableFunction to me is about taking the best thing about DataStream API and combining it with all the good things of Table API (type system, optimizer, backwards compatibility). Big +1 on this direction and proposal. Cheers, Konstantin A

Re: [DISCUSS] Release HBase connector with partial JDK support

Hi Marton, Yanquan, Thank you for your responses! Regarding the points brought up to discuss: 1. Supporting 1.20 definitely makes sense, but since there is quite a big gap to work down here now, I am not sure it should be done in 1 step. As my understanding, the externalized connector dev model [

[jira] [Created] (FLINK-36593) Upgrade io.airlift:aircompressor to mitigate CVE

Thomas Cooper created FLINK-36593: - Summary: Upgrade io.airlift:aircompressor to mitigate CVE Key: FLINK-36593 URL: https://issues.apache.org/jira/browse/FLINK-36593 Project: Flink Issue Type

[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

[jira] [Created] (FLINK-36592) Support file cache for ForStStateBackend

Yanfei Lei created FLINK-36592: -- Summary: Support file cache for ForStStateBackend Key: FLINK-36592 URL: https://issues.apache.org/jira/browse/FLINK-36592 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36591) WikipediaEditsSourceTest fails in all cases

Martijn Visser created FLINK-36591: -- Summary: WikipediaEditsSourceTest fails in all cases Key: FLINK-36591 URL: https://issues.apache.org/jira/browse/FLINK-36591 Project: Flink Issue Type: B