[jira] [Created] (FLINK-37513) CassandraSource CQL_PROHIBITED_CLAUSES_REGEXP invalid regex

Maciej Bak created FLINK-37513: -- Summary: CassandraSource CQL_PROHIBITED_CLAUSES_REGEXP invalid regex Key: FLINK-37513 URL: https://issues.apache.org/jira/browse/FLINK-37513 Project: Flink Issu

[jira] [Created] (FLINK-37510) Improve the code for SlidingEventTimeWindows

Jiaan Geng created FLINK-37510: -- Summary: Improve the code for SlidingEventTimeWindows Key: FLINK-37510 URL: https://issues.apache.org/jira/browse/FLINK-37510 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-37516) Whether to only synchronize the structure of the table.

vertern created FLINK-37516: --- Summary: Whether to only synchronize the structure of the table. Key: FLINK-37516 URL: https://issues.apache.org/jira/browse/FLINK-37516 Project: Flink Issue Type: New

[jira] [Created] (FLINK-37517) Bump flink 2.0 for elasticsearch connector

Weijie Guo created FLINK-37517: -- Summary: Bump flink 2.0 for elasticsearch connector Key: FLINK-37517 URL: https://issues.apache.org/jira/browse/FLINK-37517 Project: Flink Issue Type: Bug

Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector

Hi all, Thanks for your answers! Getting everyone aligned on this topic is challenging, but it’s definitely worth the effort since it will help streamline things moving forward. @Gabor are you saying that users are using some scripts to define the SQL metadata connector and get the information, r

Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector

Hi. After reading the doc[1], I think Spark provides a function for users to consume the metadata from the savepoint. In Flink SQL, similar functionality is implemented through Polymorphic Table Functions (PTF) as proposed in FLIP-440[2]. Below is a code example[3] illustrating this concept: ```

Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector

Hi Zaklely, Shengkai Several topics are going on so adding gist answers to them. When some topic is not touched please highlight it. @Shengkai: I've read through all the previous FLIPs related catalogs and if we would like to keep the concepts there then one-to-one mapping relationship between sa

[jira] [Created] (FLINK-37519) Add clearer logs when fail to write to YAML DataSink.

Yanquan Lv created FLINK-37519: -- Summary: Add clearer logs when fail to write to YAML DataSink. Key: FLINK-37519 URL: https://issues.apache.org/jira/browse/FLINK-37519 Project: Flink Issue Type:

Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector

Hi All! Thank you for the answers and concerns from everyone. On the CLI vs State Metadata Connector/Table question I would also like to step back a little and look at the bigger picture. I think the overall vision in Flink SQL is to provide a SQL native environment where we can serve complex us

Re: [VOTE] FLIP-509 Pluggable Batching For Async Sink

Thanks for driving this! +1 (binding) Hong On Fri, Mar 14, 2025 at 6:01 PM Danny Cranmer wrote: > Thanks for driving this Poorvank. > > +1 (binding) > > Thanks, > Danny > > > On Wed, 12 Mar 2025, 11:48 Ahmed Hamdy, wrote: > > > Thanks for addressing the feedback Poorvank, > > > > +1 (non-bind

Re: [DISCUSS] FLIP-432: Faster Checkpoint & Recovery for Disaggregated State

Hi Han, Thanks for the proposal. Faster Checkpoint & Recovery lays the groundwork for Disaggregated State to adapt to cloud-native deployment. Regarding the FLIP, I have three comments: 1. Are there any preliminary evaluation results available for this feature? 2. In terms of compatibility, can t

[jira] [Created] (FLINK-37512) SlidingEventTimeWindows causes OOM

Jiaan Geng created FLINK-37512: -- Summary: SlidingEventTimeWindows causes OOM Key: FLINK-37512 URL: https://issues.apache.org/jira/browse/FLINK-37512 Project: Flink Issue Type: Bug Comp

Re: [VOTE] FLIP-507: Add Model DDL methods in TABLE API

+1 (binding) Thank you for the update Yash. The FLIP is in a good shape now. Regards, Timo On 17.03.25 17:50, Yash Anand wrote: Hi Timo, Thank you for your feedback. I have updated the FLIP to address your questions and concerns. Please let me know if you have any other feedback. Thanks, Yas

[jira] [Created] (FLINK-37515) FLIP-503: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic)

Sergio Chong created FLINK-37515: Summary: FLIP-503: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic) Key: FLINK-37515 URL: https://issues.apache.org/jira/browse/FLINK-37515 Project: Fl

[jira] [Created] (FLINK-37511) JobPlan properties aren't listed in OpenAPI spec

Efrat Levitan created FLINK-37511: - Summary: JobPlan properties aren't listed in OpenAPI spec Key: FLINK-37511 URL: https://issues.apache.org/jira/browse/FLINK-37511 Project: Flink Issue Type

Re: [VOTE] FLIP-507: Add Model DDL methods in TABLE API

Thanks all. We have reached 3 binding votes. Sorry for the last minute changes to the FLIP. If there are no objections, I will close the vote by tomorrow. Thanks, Yash Anand On Wed, Mar 19, 2025 at 10:55 AM Timo Walther wrote: > +1 (binding) > > Thank you for the update Yash. The FLIP is in a g

Re: [DISCUSS] FLIP-515: Dynamic Kafka Sink

Hi Matyas, could you please provide more details on the KafkaMetadataService? Where does it live? How does it work? How does "Metadata state will be stored in Flink state as the source of truth for the Flink job" work? Also nit: the test plan contains copy&paste errors. Best, Arvid On Thu, Mar

Re: Community review process improvement proposal

Any time. More than happy to help in any way I can. On the subscription idea, I tackled this on companies I worked with before by using codeowners. We could have certain "groups" where the committers could join and then get notified/assigned. But rather than directly assigning, we could notify the

[jira] [Created] (FLINK-37514) Display if incremental checkpoints are enabled on Flink dashboard's checkpoints tab

Hong Liang Teoh created FLINK-37514: --- Summary: Display if incremental checkpoints are enabled on Flink dashboard's checkpoints tab Key: FLINK-37514 URL: https://issues.apache.org/jira/browse/FLINK-37514