[jira] [Created] (FLINK-37116) Add release notes for all breaking changes in 2.0.0

2025-01-13 Thread lincoln lee (Jira)
lincoln lee created FLINK-37116: --- Summary: Add release notes for all breaking changes in 2.0.0 Key: FLINK-37116 URL: https://issues.apache.org/jira/browse/FLINK-37116 Project: Flink Issue Type:

[jira] [Created] (FLINK-37115) [Benchmark] Compile error related with SerializerConfig

2025-01-13 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-37115: --- Summary: [Benchmark] Compile error related with SerializerConfig Key: FLINK-37115 URL: https://issues.apache.org/jira/browse/FLINK-37115 Project: Flink Issue T

[jira] [Created] (FLINK-37114) Flink CDC Postgres Connector subsribe regular expression will be slow

2025-01-13 Thread hql0312 (Jira)
hql0312 created FLINK-37114: --- Summary: Flink CDC Postgres Connector subsribe regular expression will be slow Key: FLINK-37114 URL: https://issues.apache.org/jira/browse/FLINK-37114 Project: Flink

Re: [VOTE] FLIP-501: Support Window Extension in DataStream V2 API

2025-01-13 Thread Zakelly Lan
+1 (binding) Windows are necessary for datastream API. Thanks for driving this. Best, Zakelly On Tue, Jan 14, 2025 at 10:56 AM Junrui Lee wrote: > +1(binding) > > Best, > Junrui > > weijie guo 于2025年1月14日周二 10:32写道: > > > +1(binding) > > > > Best regards, > > > > Weijie > > > > > > Xu Huang

[jira] [Created] (FLINK-37113) Introduce document for datastream api v2

2025-01-13 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-37113: -- Summary: Introduce document for datastream api v2 Key: FLINK-37113 URL: https://issues.apache.org/jira/browse/FLINK-37113 Project: Flink Issue Type: New Feature

Re: [DISCUSSION] flink-connector-hive first release of externalized connector

2025-01-13 Thread Ron Liu
+1 Best, Ron yuxia 于2025年1月14日周二 10:17写道: > Thanks Sergey for driving this work again.. > +1 for externalizing hive connector to finish all connector externalizing > for Flink.. > > Best regards, > Yuxia > > - 原始邮件 - > 发件人: "Jark Wu" > 收件人: "dev" > 发送时间: 星期二, 2025年 1 月 14日 上午 10:06:42

[jira] [Created] (FLINK-37112) FLIP-499: Support Event Time by Generalized Watermark in DataStream V2

2025-01-13 Thread xuhuang (Jira)
xuhuang created FLINK-37112: --- Summary: FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 Key: FLINK-37112 URL: https://issues.apache.org/jira/browse/FLINK-37112 Project: Flink

Re: [VOTE] FLIP-500: Support Join Extension in DataStream V2 API

2025-01-13 Thread Junrui Lee
+1(binding) Best, Junrui weijie guo 于2025年1月14日周二 10:32写道: > +1(binding) > > Best regards, > > Weijie > > > Xu Huang 于2025年1月13日周一 14:55写道: > > > Hi, all. > > > > I'd like to start a vote on FLIP-500: Support Join Extension in > DataStream > > V2 API [1]. You can find the discussion on it here

Re: [VOTE] FLIP-501: Support Window Extension in DataStream V2 API

2025-01-13 Thread Junrui Lee
+1(binding) Best, Junrui weijie guo 于2025年1月14日周二 10:32写道: > +1(binding) > > Best regards, > > Weijie > > > Xu Huang 于2025年1月13日周一 14:37写道: > > > Hi, all. > > > > I'd like to start a vote on FLIP-501: Support Window Extension in > > DataStream V2 API [1]. You can find the discussion on it here

[jira] [Created] (FLINK-37111) Allow setting `sink.version` for StarRocks Pipeline connector

2025-01-13 Thread yux (Jira)
yux created FLINK-37111: --- Summary: Allow setting `sink.version` for StarRocks Pipeline connector Key: FLINK-37111 URL: https://issues.apache.org/jira/browse/FLINK-37111 Project: Flink Issue Type: Im

RE: [VOTE] FLIP-501: Support Window Extension in DataStream V2 API

2025-01-13 Thread wenjin
+1 (non-binding) Best regards, Wenjin On 2025/01/13 06:36:52 Xu Huang wrote: > Hi, all. > > I'd like to start a vote on FLIP-501: Support Window Extension in > DataStream V2 API [1]. You can find the discussion on it here [2]. > > The vote will last for at least 72 hours unless there is objecti

RE: [VOTE] FLIP-500: Support Join Extension in DataStream V2 API

2025-01-13 Thread xie wenjin
+1 (non-binding) Thanks for driving it! Best regards, Wenjin On 2025/01/13 06:55:22 Xu Huang wrote: > Hi, all. > > I'd like to start a vote on FLIP-500: Support Join Extension in DataStream > V2 API [1]. You can find the discussion on it here[2]. > > The vote will last for at least 72 hours un

Re: [VOTE] FLIP-500: Support Join Extension in DataStream V2 API

2025-01-13 Thread weijie guo
+1(binding) Best regards, Weijie Xu Huang 于2025年1月13日周一 14:55写道: > Hi, all. > > I'd like to start a vote on FLIP-500: Support Join Extension in DataStream > V2 API [1]. You can find the discussion on it here[2]. > > The vote will last for at least 72 hours unless there is objection or > insuf

Re: [VOTE] FLIP-501: Support Window Extension in DataStream V2 API

2025-01-13 Thread weijie guo
+1(binding) Best regards, Weijie Xu Huang 于2025年1月13日周一 14:37写道: > Hi, all. > > I'd like to start a vote on FLIP-501: Support Window Extension in > DataStream V2 API [1]. You can find the discussion on it here [2]. > > The vote will last for at least 72 hours unless there is objection or > in

Re: [DISCUSSION] flink-connector-hive first release of externalized connector

2025-01-13 Thread yuxia
Thanks Sergey for driving this work again.. +1 for externalizing hive connector to finish all connector externalizing for Flink.. Best regards, Yuxia - 原始邮件 - 发件人: "Jark Wu" 收件人: "dev" 发送时间: 星期二, 2025年 1 月 14日 上午 10:06:42 主题: Re: [DISCUSSION] flink-connector-hive first release of exter

Re: [DISCUSSION] flink-connector-hive first release of externalized connector

2025-01-13 Thread Leonard Xu
Thanks Sergey for picking up this ticket, +1 from my side. Best, Leonard > 2025年1月14日 10:06,Jark Wu 写道: > > +1 for externalizing hive connector > > Best, > Jark > > On Tue, 14 Jan 2025 at 10:01, Lincoln Lee wrote: > >> Thanks Sergey for driving this important work! >> >> +1 for finishing t

Re: [DISCUSSION] flink-connector-hive first release of externalized connector

2025-01-13 Thread Jark Wu
+1 for externalizing hive connector Best, Jark On Tue, 14 Jan 2025 at 10:01, Lincoln Lee wrote: > Thanks Sergey for driving this important work! > > +1 for finishing the externalize. > > > Best, > Lincoln Lee > > > Sergey Nuyanzin 于2025年1月14日周二 06:16写道: > > > Hi everyone, > > > > This is yet a

Re: [DISCUSSION] flink-connector-hive first release of externalized connector

2025-01-13 Thread Lincoln Lee
Thanks Sergey for driving this important work! +1 for finishing the externalize. Best, Lincoln Lee Sergey Nuyanzin 于2025年1月14日周二 06:16写道: > Hi everyone, > > This is yet another iteration to request/propose release of external Hive > connector. > Unfortunately the first attempt (about a year

[jira] [Created] (FLINK-37110) When the database and schema names of the regular expression are the same, the results of table selector filtering will be incorrect.

2025-01-13 Thread Jira
林健昌 created FLINK-37110: --- Summary: When the database and schema names of the regular expression are the same, the results of table selector filtering will be incorrect. Key: FLINK-37110 URL: https://issues.apache.org/jira/

[DISCUSS] FLIP-XXX: Blue/Green Deployments for Flink on Kubernetes: Phase 2 (with Coordination)

2025-01-13 Thread Sergio Chong Loo
Hi folks, As mentioned in [1], this FLIP represents the 2nd phase to add Blue/Green deployments support. This phase adds the capability to coordinate, in a more granular and extensible way, the transition between the 2 jobs. Here’s the Google Doc: https://docs.google.com/document/d/1ee-75ZFp

[jira] [Created] (FLINK-37109) Increase state processor API performance when reading keyed rocksdb state

2025-01-13 Thread Gary Lam (Jira)
Gary Lam created FLINK-37109: Summary: Increase state processor API performance when reading keyed rocksdb state Key: FLINK-37109 URL: https://issues.apache.org/jira/browse/FLINK-37109 Project: Flink

[DISCUSS] FLIP-XXX: Blue/Green Deployments for Flink on Kubernetes: Phase 1 (basic)

2025-01-13 Thread Sergio Chong Loo
Hi folks, As proposed in [1] we would like to more formally continue the discussion to add Blue/Green deployments support to Flink via the Kubernetes Operator. For clarity and easier review experience we’ve separated this effort into 2 phases: 1) Blue/Green Deployments for Flink on Kubernetes:

[DISCUSSION] flink-connector-hive first release of externalized connector

2025-01-13 Thread Sergey Nuyanzin
Hi everyone, This is yet another iteration to request/propose release of external Hive connector. Unfortunately the first attempt (about a year ago[1]) was not able to attract enough binding votes. There is already a discussion about this in the comments of [2]. And also want to bring to ML. Now

Re: [DISCUSS] FLIP-498: AsyncTableFunction for async table function support

2025-01-13 Thread Alan Sheinberg
I just wanted to add a little bit to my response as I considered the previous FLIP. I support FLIP-313 and the proposal of the original author. I wasn't trying to take it over, but wanted to show renewed interest. I'm also focused on a smaller MVP, which is why I omitted hint support, which seeme

Re: [DISCUSS] FLIP-498: AsyncTableFunction for async table function support

2025-01-13 Thread Alan Sheinberg
Thanks for the responses Timo, Dawid. > However, why have you decided to resubmit the FLIP with a newer number > rather than following up on FLIP-313? The only difference I see between the > two FLIPs is the options/hints design. Could you elaborate where the > differences come from? I think yo

Re: [DISCUSS] FLIP-498: AsyncTableFunction for async table function support

2025-01-13 Thread Dawid Wysakowicz
Generally what is suggested here makes sense to me. However, why have you decided to resubmit the FLIP with a newer number rather than following up on FLIP-313? The only difference I see between the two FLIPs is the options/hints design. Could you elaborate where the differences come from? Best,

Re: [DISCUSS] FLIP-498: AsyncTableFunction for async table function support

2025-01-13 Thread Timo Walther
Hi Alan, thanks for proposing this FLIP. I agree that AsyncTableFunction is very similar to AsyncScalarFunction and luckily, the Python component has laid the foundation for this proposal. Nothing to add from my side. +1 for voting. Regards, Timo On 02.01.25 20:47, Alan Sheinberg wrote: I

Re: [DISCUSS] FLIP-491: BundledAggregateFunction for batched aggregation

2025-01-13 Thread Timo Walther
Hi Alan, thanks for sharing this FLIP with us. Sorry for the late reply. I think the FLIP is already in a very good shape. I like the approach that the BundledAggregateFunction is rather a separate interface that can be implemented by advanced users. This matches with the existing Specialize

Re: [DISCUSS] FLIP-502: QueryOperation SQL Serialization customization

2025-01-13 Thread Timo Walther
Hi Dawid, thanks for proposing this FLIP. It nicely completes the serialization effort started with FLIP-393. I know naming is difficult, but could we shorten and simplify the signatures further? My suggestion would be: OperationSerializationContext -> SqlSerializationContext ExpressionSerial

[jira] [Created] (FLINK-37108) Source/Sink test suites test invalid recovery

2025-01-13 Thread Arvid Heise (Jira)
Arvid Heise created FLINK-37108: --- Summary: Source/Sink test suites test invalid recovery Key: FLINK-37108 URL: https://issues.apache.org/jira/browse/FLINK-37108 Project: Flink Issue Type: Impro

[RESULT][VOTE] FLIP-496: SQL connector for keyed state data

2025-01-13 Thread Gabor Somogyi
Hi All, I'm glad to announce that the FLIP-496: SQL connector for keyed state data[1] has been accepted. The voting thread is here[2]. The proposal received 4 approving votes, 4 of which are binding: - Zakelly Lan (binding) - Marton Balassi (binding) - Ferenc Csaky (binding) - Gabor Somogyi (bin

Re: [VOTE] FLIP-496: SQL connector for keyed state data

2025-01-13 Thread Gabor Somogyi
Also +1 from my side. Thank you all for voting. Voting is closed. BR, G On Sat, Jan 11, 2025 at 11:36 AM Ferenc Csaky wrote: > +1 (binding) > > Looking forward to this! > > Best, > Ferenc > > > > > On Friday, January 10th, 2025 at 12:28, Márton Balassi < > balassi.mar...@gmail.com> wrote: > >

Re:Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join

2025-01-13 Thread Xuyang
Hi, Weiqing. After reading the new FLIP, I have no issues with the part `public interface`. I only have some questions regarding the details in the Proposed Changes section. Regarding the ModifyKind and UpdateKind of the IntervalJoin node, IIUC: - When early firing is enabled, the UpdateKin

[jira] [Created] (FLINK-37107) Allow buffer overdraft in async state processing

2025-01-13 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-37107: --- Summary: Allow buffer overdraft in async state processing Key: FLINK-37107 URL: https://issues.apache.org/jira/browse/FLINK-37107 Project: Flink Issue Type: Su