Re: [DISCUSS] FLIP-521: Integrating Variant Type into Flink: Enabling Efficient Semi-Structured Data Processing

2025-04-30 Thread Aihua Xu
Hi Xuannan, Are we planning to support Variant shredding in the future or just basic variant encoding for Flink? Thanks, Aihua

Re: [VOTE] Apache Flink CDC Release 3.4.0, release candidate #3

2025-04-30 Thread Xiqian YU
Thanks Kunni for preparing this release! +1 (non-binding) - verified tarball checksum and signatures are valid - confirmed jar files were built with JDK 1.8.0_392 and Apache Maven 3.8.6, bytecode version is 52.0 - ran simple data integration job with schema evolution - ran transform performance b

Re: [DISCUSS] FLIP-527 Support EXPLAIN EXECUTE STATEMENT SET Syntax in Flink SQL

2025-04-30 Thread Dawid Wysakowicz
I’m also +1. Our production experience show the current syntax is very confusing. Prepending a query with an explain works in all other cases but statement set as Timo mentioned. Best, Dawid On Wed, 30 Apr 2025 at 15:23, Timo Walther wrote: > Hi Ramin, > > it was a mistake to support the EXPLA

Re: [DISCUSS] FLIP-527 Support EXPLAIN EXECUTE STATEMENT SET Syntax in Flink SQL

2025-04-30 Thread Timo Walther
Hi Ramin, it was a mistake to support the EXPLAIN STATEMENT SET syntax in the first place. We support `EXPLAIN SELECT` and `EXPLAIN CREATE TABLE`, so EXPLAIN + verb, we should have done the same for `EXECUTE`. +1 for the proposal. Cheers, Timo On 30.04.25 11:55, Gustavo de Morais wrote: I

Re: [DISCUSS] FLIP-516: Multi-Way Join Operator

2025-04-30 Thread Gustavo de Morais
Hey Arvid and David, thanks for the feedback! The limitations are in the flip, I just had pasted a wrong link and fixed it. Let me know if there are other incorrect links. Yes, the thought of using statistics has potential. I've also spent some on that. The precise statistics required here would

Re: KinesisStreamSource de-aggregation support via DeserializationSchema

2025-04-30 Thread Lorenzo Nicora
Thanks Ahmed I think I didn't express myself fully. The issue with a major release is not just timing, We should also put this from the perspective of the user. Particularly not-so-expert users. Because the change breaks the interface of @PublicEvolving class, in particular the interface KinesisD

Re: [DISCUSS] FLIP-527 Support EXPLAIN EXECUTE STATEMENT SET Syntax in Flink SQL

2025-04-30 Thread Gustavo de Morais
I agree with Martijn. It’s just a better, consistent user experience. Also, we keep backwards compatibility, so I see no reason for not doing it. I’d also be +1 for this. Am Di., 29. Apr. 2025 um 09:42 Uhr schrieb Martijn Visser < martijnvis...@apache.org>: > Hi all, > > Thanks for the FLIP Rami

[jira] [Created] (FLINK-37752) Make 'json.decode.json-parser.enabled' take effect

2025-04-30 Thread Hongjia Liang (Jira)
Hongjia Liang created FLINK-37752: - Summary: Make 'json.decode.json-parser.enabled' take effect Key: FLINK-37752 URL: https://issues.apache.org/jira/browse/FLINK-37752 Project: Flink Issue Ty