Re: [VOTE] FLIP-526: Model ML_PREDICT, ML_EVALUATE Table API

2025-05-29 Thread Piotr Nowojski
+1 (binding) Best, Piotrek czw., 29 maj 2025 o 05:58 Shengkai Fang napisał(a): > +1(binding) > > Best, > Shengkai > > Timo Walther 于2025年5月29日周四 00:00写道: > > > +1 (binding) > > > > We should still check whether changes to QueryOperationVisitor are > > necessary but this is internal API and sho

Re: Proposal Flip-233: Donate GetInData HTTP Connector to Flink

2025-05-29 Thread Krzysztof Zarzycki
Hi all, Krzysztof Zarzycki, CTO of Getindata (soon to be Xebia) here, I lead the group that developed the connector and collaborates with David on it further. Thank you David for starting the thread, as we chatted. We as Getindata would be delighted to offer the repository to the Flink community.

[jira] [Created] (FLINK-37873) 【Hbase-connector】Enable buffer flush, specify a non-existent table when writing data to hbase, the Flink task displays successful

2025-05-29 Thread Xin Chen (Jira)
Xin Chen created FLINK-37873: Summary: 【Hbase-connector】Enable buffer flush, specify a non-existent table when writing data to hbase, the Flink task displays successful Key: FLINK-37873 URL: https://issues.apache.org

Re: [DISCUSS] FLIP-529 Connections in Flink SQL and Table API

2025-05-29 Thread Leonard Xu
Hey Mayank. Thanks for the FLIP, I went through this FLIP quickly and found some issues which I think we need to deep discuss later. As we’re on a short Dragon boat Festival, could you kindly hold on this thread? and we will back to continue the FLIP discuss. Best, Leonard > 2025 4月 29 23

Re: [DISCUSS] Migrate state processor API from source v1 to source v2 API

2025-05-29 Thread Zakelly Lan
Hi Gabor, To be more specific, I'm thinking of introducing `RichSourceReaderContext`, and having a `RichSourceReaderFactory` creating `SourceReader` on top of the rich context. Or we still use the `SourceReaderFactory` but do type conversion from `SourceReaderContext` to `RichSourceReaderContext`

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

2025-05-29 Thread MOBIN
+1, thanks for driving this release! Looking forward to the arrival of version 3.5! At 2025-05-27 11:36:40, "Yanquan Lv" wrote: >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 ha

[jira] [Created] (FLINK-37872) Autoscaler computes negative true processing rate

2025-05-29 Thread Sai Sharath Dandi (Jira)
Sai Sharath Dandi created FLINK-37872: - Summary: Autoscaler computes negative true processing rate Key: FLINK-37872 URL: https://issues.apache.org/jira/browse/FLINK-37872 Project: Flink I

[jira] [Created] (FLINK-37871) Remove FlinkRelMdUtil#getJoinDistinctRowCount

2025-05-29 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-37871: --- Summary: Remove FlinkRelMdUtil#getJoinDistinctRowCount Key: FLINK-37871 URL: https://issues.apache.org/jira/browse/FLINK-37871 Project: Flink Issue Typ

Re: [DISCUSS] FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch

2025-05-29 Thread Becket Qin
Hi Allison, Thanks for updating the FLIP. The latest Looks good to me. I think we can move forward to voting. Thanks, Jiangjie (Becket) Qin On Thu, May 22, 2025 at 1:26 PM Allison wrote: > Hi Becket, > > Thank you for your feedback. I have updated the FLIP-505 proposal to > reflect these comm

Re: Proposal Flip-233: Donate GetInData HTTP Connector to Flink

2025-05-29 Thread Sharath
+1 (non-binding). I think this would be a great addition as well! On Thu, May 29, 2025 at 9:28 AM Tom Cooper wrote: > +1 (non-binding) from me! This seems like it would be a really useful > functionality to have within Flink. > > Can we get some official notice (email on this thread, Github > di

Re: Proposal Flip-233: Donate GetInData HTTP Connector to Flink

2025-05-29 Thread Tom Cooper
+1 (non-binding) from me! This seems like it would be a really useful functionality to have within Flink. Can we get some official notice (email on this thread, Github discussion/issue) from the GetInData folks and other maintainers that they are happy to donate the project to Flink and would b

Re: [DISCUSS] Decouple PyFlink wheel package build from Azure

2025-05-29 Thread Ferenc Csaky
Hi Dian, This is awesome, thanks for the quick action on merging the backport PRs! I'll proceed with the release process based on this, and update the docs as well. Thanks, Ferenc On Thursday, May 29th, 2025 at 04:59, Dian Fu wrote: > > > Hi Ferenc, > > This should have already been suppo

Re: Need invite link for the Flink community on Slack

2025-05-29 Thread Leonard Xu
Thanks Yanquan, would you like to open a PR to update our website link as well? Best, Leonard > 2025 5月 29 11:39,Yanquan Lv 写道: > > Hi, Siva. > > You can use this link[1] to join Flink community on Slack. > We will update the link on getting-help page later. > > [1] > https://apache-flink.sla

[DISCUSS] Flink CDC 3.5 Kick Off

2025-05-29 Thread Leonard Xu
Thanks Yanquan for volunteering to driving the Flink CDC 3.5 version. +1 for the plan, code freeze date and release manager candidate. Feel free to ping me if you need any help from PMC side. Best, Leonard > 2025 5月 27 11:36,Yanquan Lv 写道: > > Hi devs, > > As FlinkCDC 3.4 was released rece

Re: [DISCUSS] Migrate state processor API from source v1 to source v2 API

2025-05-29 Thread Gabor Somogyi
Hi Zakelly, Before we go into any details I can say that if we can expose the less the better so agree with you on the direction. On the technical level not yet understand what exactly you're suggesting. `RichInputFormat` is a \@Public API where we expose `RuntimeContext` now on V1. I would like

Re: Need invite link for the Flink community on Slack

2025-05-29 Thread Siva Ram Gujju
Thank you! On Wed, May 28, 2025 at 11:39 PM Yanquan Lv wrote: > Hi, Siva. > > You can use this link[1] to join Flink community on Slack. > We will update the link on getting-help page later. > > [1] > > https://apache-flink.slack.com/join/shared_invite/zt-36qpbfpc0-wtlsC7lmeEUy5cw0VTHdag#/shared

[jira] [Created] (FLINK-37870) Unaligned checkpoint is disabled unexpectedly

2025-05-29 Thread Rui Fan (Jira)
Rui Fan created FLINK-37870: --- Summary: Unaligned checkpoint is disabled unexpectedly Key: FLINK-37870 URL: https://issues.apache.org/jira/browse/FLINK-37870 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-37869) Bouned job can't be cleanup by the Flink Kuberenetes Operator

2025-05-29 Thread junzhong qin (Jira)
junzhong qin created FLINK-37869: Summary: Bouned job can't be cleanup by the Flink Kuberenetes Operator Key: FLINK-37869 URL: https://issues.apache.org/jira/browse/FLINK-37869 Project: Flink

[jira] [Created] (FLINK-37868) Respect the `maxTransferBytes` when using path copying in ForSt

2025-05-29 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-37868: --- Summary: Respect the `maxTransferBytes` when using path copying in ForSt Key: FLINK-37868 URL: https://issues.apache.org/jira/browse/FLINK-37868 Project: Flink

[jira] [Created] (FLINK-37867) ForSt StateBackend fail to clean up files of the half-uploaded checkpoint when using path copying

2025-05-29 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-37867: --- Summary: ForSt StateBackend fail to clean up files of the half-uploaded checkpoint when using path copying Key: FLINK-37867 URL: https://issues.apache.org/jira/browse/FLINK-37867

Re: [DISCUSS] Migrate state processor API from source v1 to source v2 API

2025-05-29 Thread Zakelly Lan
Hi Gabor, Good point for the migration. I took a brief look. I thought the `RuntimeContext` is too powerful and might not be suitable to expose on \@Public API. Is it possible to introduce another 'rich' code path just like the difference between `RichInputFormat` and `InputFormat`, and keep that

[jira] [Created] (FLINK-37866) Migrate glue schema registry e2e test to use aws-kinesis-streams connector

2025-05-29 Thread Daren Wong (Jira)
Daren Wong created FLINK-37866: -- Summary: Migrate glue schema registry e2e test to use aws-kinesis-streams connector Key: FLINK-37866 URL: https://issues.apache.org/jira/browse/FLINK-37866 Project: Flink