[DISCUSS] FLIP-517: Better Handling of Dynamic Table Primitives with PTFs

Hi everyone, I would like to start a discussion about FLIP-517: Better Handling of Dynamic Table Primitives with PTFs [1]. In the past months, I have spent a significant amount of time with SQL semantics and the SQL standard around PTFs, when designing and implementing FLIP-440 [2]. For thos

Submitting multiple DELETE statements in Flink SQL

I' m trying to submit multiple DELETE statements in to the TableEnvironment in way: val settings = EnvironmentSettings.newInstance.inBatchMode.build() val env = TableEnvironment.create(settings) createSchema(env) val queries = getDeleteQueries queries.foreach(q => env.executeSql(q).await()) what

[DISCUSS] FLIP-518: Introduce a community review process

I would like to start a discussion around FLIP-518 which proposes a new community review process. Please let me know if you support this idea, or would like changes. We hope this process improvement will * Encourage more people in the community

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

Hi all, Thanks for your review and the votes! I am happy to announce that FLIP-507: Add Model DDL methods in TABLE API [1] has been accepted. There are 3 binding votes and 2 non-binding votes [2]: - Hao Li (non-binding) - Mingge Deng (non-binding) - Dawid Wysakowicz (binding) - Leonard Xu (bind

[jira] [Created] (FLINK-37533) Reduce Stale PR Action timeouts

Thomas Cooper created FLINK-37533: - Summary: Reduce Stale PR Action timeouts Key: FLINK-37533 URL: https://issues.apache.org/jira/browse/FLINK-37533 Project: Flink Issue Type: Improvement

CHI: Add liiniting checks to all PRs

Hey All, I wanted to start a discussion on enabling linting checks, via a GitHub Action, on all PRs in the main Flink repository. Often when a user submits a PR they will wait for the CI to run in Azure DevOps and this will fail as they have forgotten to run spotless or checkstyle. However, in

Re: [VOTE] FLIP-503: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic)

+1 (binding) On Thu, Mar 20, 2025 at 4:53 PM Pedro Mázala wrote: > One question. > > When we say > > > > >- Records/data will be duplicated for as long as both pipelines are > >running concurrently > > > > > Do we mean the source record will be forwarded to both pipelines? I'm > asking t

Re: [VOTE] FLIP-503: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic)

+1 (binding) Thanks, Ferenc On Friday, March 21st, 2025 at 14:48, Őrhidi Mátyás wrote: > > > +1 (binding) > > On Thu, Mar 20, 2025 at 12:22 AM Gyula Fóra gyf...@apache.org wrote: > > > +1 (binding) > > > > And a gentle reminder to please vote :) > > > > Cheers, > > Gyula > > > > On T

Re: [VOTE] FLIP-503: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic)

+1 (binding) On Thu, Mar 20, 2025 at 12:22 AM Gyula Fóra wrote: > +1 (binding) > > And a gentle reminder to please vote :) > > Cheers, > Gyula > > On Tue, Mar 11, 2025 at 3:02 PM Gyula Fóra wrote: > > > Hi all, > > > > I would like to start the vote for FLIP-503: Blue/Green Deployments for > >

2025/03/20 CHI Western time zone workgroup meeting minutes

Hi, We help the 16th 30 minute working meeting of the Community Health Initiative (CHI) for Western time zone. The minutes were : * 23 PRs came in this week * Pedro Mazala joined the workgroup - welcome * We talked about the community review and agreed that I will

[jira] [Created] (FLINK-37532) Job recovery always starts from initialSavepointPath when JobManager HA is disabled in case of jobManger failure

Jun He created FLINK-37532: -- Summary: Job recovery always starts from initialSavepointPath when JobManager HA is disabled in case of jobManger failure Key: FLINK-37532 URL: https://issues.apache.org/jira/browse/FLINK-37

[DISCUSS] Release externalized Kudu connector

Hello devs, I would like to start a discussion to release the externalized Kudu connector. To make anyone up to date regarding what happened until now and why, let me summarize the story. Originally, the Kudu connector was part of the Bahir Flink [1] repository, but it was moved into the attic

[jira] [Created] (FLINK-37529) Add flink-cdc-commo to the package to all the incremental source framework

Hongshun Wang created FLINK-37529: - Summary: Add flink-cdc-commo to the package to all the incremental source framework Key: FLINK-37529 URL: https://issues.apache.org/jira/browse/FLINK-37529 Project:

[jira] [Created] (FLINK-37530) Upgrade savepoints are not added to deprecated savepointinfo

Gyula Fora created FLINK-37530: -- Summary: Upgrade savepoints are not added to deprecated savepointinfo Key: FLINK-37530 URL: https://issues.apache.org/jira/browse/FLINK-37530 Project: Flink Iss