[jira] [Created] (FLINK-37851) Migrate state processor API from source API v1 to source API v2

2025-05-26 Thread Gabor Somogyi (Jira)
Gabor Somogyi created FLINK-37851: - Summary: Migrate state processor API from source API v1 to source API v2 Key: FLINK-37851 URL: https://issues.apache.org/jira/browse/FLINK-37851 Project: Flink

Re: [DISCUSS] FLIP-XXX: Flink Events Reporter System

2025-05-26 Thread Li Wang
Hi Kartikey, Thanks for the FLIP. I think this Events Reporter System idea is very good for Flink. We truly need more deep insight, not just metrics, especially for achieving autonomous operations. The V1 plan looks very practical. Focus on core parts and use asynchronous dispatch for stability i

Re: [VOTE] FLIP-313: Add support of User Defined AsyncTableFunction

2025-05-26 Thread Becket Qin
Thanks for pointing to FLIP-498, Timo. I missed that. >From the FLIP-498 discussion thread, it is unclear to me whether people had agreed to "discard" FLIP-313. The FLIP-498 discussion mentioned that we may potentially still add the hint based options later, which is what was proposed in FLIP-313.

Re: Getting "sun.rmi.registry is not visible" exception while running main method of CliFrontend.java class of flink-clients package

2025-05-26 Thread pranav tiwari
Hi, Please guide me for the problem mentioned in the trailing mail. On Mon, 26 May 2025 at 7:09 PM, pranav tiwari wrote: > Hi, > > I recently cloned the Flink source code, and am trying to run the main > method of the *CliFrontend.java *class of the *flink-clients* package, > but getting the fo

Re: Getting "sun.rmi.registry is not visible" exception while running main method of CliFrontend.java class of flink-clients package

2025-05-26 Thread Ferenc Csaky
Hi, What branch and JDK version are you using? Is should not be necessary to configure `--add-opens` by hand. In the past, I ran into problems like this, when I was moving back and forth between JDK versions, and sometimes the IDE can stuck in a confused state. In general, I would suggest to i

[jira] [Created] (FLINK-37854) UnsupportedTemporalTypeException: Unsupported field: OffsetSeconds

2025-05-26 Thread Jacky Lau (Jira)
Jacky Lau created FLINK-37854: - Summary: UnsupportedTemporalTypeException: Unsupported field: OffsetSeconds Key: FLINK-37854 URL: https://issues.apache.org/jira/browse/FLINK-37854 Project: Flink

[Discuss] Flink CDC 3.4 Kick Off, [Discuss] Flink CDC 3.5 Kick Off

2025-05-26 Thread Yanquan Lv
Hi devs, As FlinkCDC 3.4 was released recently, it's a good time to kick off the upcoming Flink CDC 3.5 release cycle. In the past two major versions, we have made significant optimizations to the capability of schema evolution, this feature is quite stable now. In this version, we will focus on

Re: [Discuss] Flink CDC 3.4 Kick Off, [Discuss] Flink CDC 3.5 Kick Off

2025-05-26 Thread Yanquan Lv
sorry for the title and update: [Discuss] Flink CDC 3.5 Kick Off Yanquan Lv 于2025年5月27日周二 11:36写道: > Hi devs, > > As FlinkCDC 3.4 was released recently, it's a good time to kick off the > upcoming Flink CDC 3.5 release cycle. > > In the past two major versions, we have made significant optimiza

Re: [Discuss] Flink CDC 3.4 Kick Off, [Discuss] Flink CDC 3.5 Kick Off

2025-05-26 Thread Xiqian YU
+1, thanks for driving this release! Best Regards, Xiqian > 2025年5月27日 11:38,Yanquan Lv 写道: > > sorry for the title and update: > [Discuss] Flink CDC 3.5 Kick Off > > > Yanquan Lv 于2025年5月27日周二 11:36写道: > >> Hi devs, >> >> As FlinkCDC 3.4 was released recently, it's a good time to kick off

[DISCUSS] Deprecating/dropping support for Python 3.8

2025-05-26 Thread Mika Naylor
Hi all, I recently wanted to look into using the new dependency groups mechanism for centralising testing/development requirements in one place in a consistent format, rather than scattered in various places. I opened FLINK-37775 to reflect this, but had to drop it as it's only a feature in new

Re: [DISCUSS] Projection pushdown support in Flink Kafka Table connector

2025-05-26 Thread Farooq Qaiser
Hey folks, Just wanted to give this thread a quick bump for visibility. Thanks, Farooq On Fri, May 9, 2025 at 12:04 PM Farooq Qaiser wrote: > Hi folks, > > Just wanted to share a PR I've been working on to add support for > projection pushdown to the Flink Kafka Table connector: > https://gith

[jira] [Created] (FLINK-37852) SQL Server CDC cannot capture changes from tables with special characters

2025-05-26 Thread Sergei Morozov (Jira)
Sergei Morozov created FLINK-37852: -- Summary: SQL Server CDC cannot capture changes from tables with special characters Key: FLINK-37852 URL: https://issues.apache.org/jira/browse/FLINK-37852 Project

Re: [VOTE] FLIP-530: Dynamic job configuration

2025-05-26 Thread Roman Khachatryan
Hi everyone, I'm happy to announce that FLIP-530: Dynamic job configuration [1] has been accepted. There were 8 approving votes, 4 of which were binding: - Piotr Nowojski (binding) - Hao Li (non-binding) - Junrui Lee (binding) - Hangxiang Yu (binding) - Fefan Wang (non-binding) - Rui Fan (bindin

[jira] [Created] (FLINK-37853) FLIP-530: Dynamic job configuration

2025-05-26 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-37853: - Summary: FLIP-530: Dynamic job configuration Key: FLINK-37853 URL: https://issues.apache.org/jira/browse/FLINK-37853 Project: Flink Issue Type: Imp

Re: [DISCUSS] FLIP-531: Initiate Flink Agents as a new Sub-Project

2025-05-26 Thread Jing Ge
Fair enough! Thanks Xintong for the clarification! Looking forward to it! Best regards, Jing On Mon, May 26, 2025 at 3:48 AM Xintong Song wrote: > @Robert, > > 1. I wasn't aware of the ASF subproject concept. Yes, the intention here is > to create a repository, just like flink-cdc, flink-kubern

Getting "sun.rmi.registry is not visible" exception while running main method of CliFrontend.java class of flink-clients package

2025-05-26 Thread pranav tiwari
Hi, I recently cloned the Flink source code, and am trying to run the main method of the *CliFrontend.java *class of the *flink-clients* package, but getting the following error message- *package sun.rmi.registry is not visible (package sun.rmi.registry is declared in module java.rmi, which do

Re: [VOTE] FLIP-313: Add support of User Defined AsyncTableFunction

2025-05-26 Thread Timo Walther
-1 This FLIP has been subsumed by FLIP-498: AsyncTableFunction for async table function support [1]. In the discussion for FLIP-498, we decided to discard FLIP-313 as it has been abandoned for a while. I hope this is ok for everyone. @Alan might give some timeline when this feature will land

Re:Re: Re: Re: Re: [DISCUSS] FLIP-486: Introduce a new DeltaJoin

2025-05-26 Thread Xuyang
Hi, Gustavo. Oh, I apologize for not noticing your reply before... 1. The quick answer is that as long as at least one streaming join is transformed into a delta join, FORCE will not raise an error. 2. Related to FLIP-516, I am also gradually working on a POC for multi-way delta join, but it ma