Re: [VOTE] Release flink-connector-elasticsearch v4.0.0, release candidate #1

2025-04-08 Thread Yanquan Lv
+1 (non-binding) I checked: - Review JIRA release notes - Verify hashes and verify signatures - Build success from source with JDK11 & maven3.8.6 - Source code artifacts matching the current release - Read the announcement blog and LGTM - Run a datagen to elasticsearch7 test with Flink 2.0 cluster

Re: How to add flink bot in flink subprojects(such as flink-connector-kafka)

2025-04-08 Thread Hongshun Wang
Hi Robert, It seems that flinkbot was added by you, would you like to give some introduction. Best Hongshun On Wed, Apr 9, 2025 at 1:51 PM Hongshun Wang wrote: > Dear Devs, > > Currently, flinkbot[1] is very helpful to rerun failed tests. Anyone know > how to add this to flink subprojects(such

How to add flink bot in flink subprojects(such as flink-connector-kafka)

2025-04-08 Thread Hongshun Wang
Dear Devs, Currently, flinkbot[1] is very helpful to rerun failed tests. Anyone know how to add this to flink subprojects(such as flink-connector-kafka, flink cdc)? It's inconvenient for developers who are not a committer. After each modification or unstable fail test, we have to ping a committer

Re: [DISCUSS] FLIP-519: Introduce async lookup key ordered mode

2025-04-08 Thread Zakelly Lan
Thanks for driving this! +1 for the FLIP given there is a solid user case behind. Shuai and I had a discussion and we agree that `KeyedAsyncWaitOperator` in current FLIP shares similar functionality with the `Asynchronous Execution Model (AEC)` introduced in FLIP-425[1]. We think it is better to

Re: [VOTE] Release flink-connector-kafka v4.0.0, release candidate #1

2025-04-08 Thread Xiqian YU
+1 (non-binding) Checklist: - Verified tarball checksum & signatures are valid - Compiled source code locally with JDK 17 - Verified test cases locally and all passed - Reviewed flink-web PR and release notes Best Regards, Xiqian > 2025年4月8日 22:08,Arvid Heise 写道: > > Hi everyone, > Please rev

Re: [VOTE] Release flink-connector-kafka v4.0.0, release candidate #1

2025-04-08 Thread Arvid Heise
Hi Yanquan, Thank you for noticing that. I do think we should support 11 and thus I will recompile it. I'm retracting RC1 and will build RC2 soonish. Best, Arvid On Wed, Apr 9, 2025, 06:22 Yanquan Lv wrote: > Hi, Arvid. Thanks for your efforts in this release. > > I noticed that this release

Re: [VOTE] Release flink-connector-elasticsearch v4.0.0, release candidate #1

2025-04-08 Thread Hongshun Wang
Hi Weijie Should we update NOTICE[1] to 2025 before release? [1] https://github.com/apache/flink-connector-elasticsearch/blob/main/NOTICE Best Hongshun On Mon, Apr 7, 2025 at 8:06 PM Zakelly Lan wrote: > +1 (binding) > > I have verified: > > - Checksum and signature > - There are no binaries

[jira] [Created] (FLINK-37636) Weekly CI failure

2025-04-08 Thread Yanquan Lv (Jira)
Yanquan Lv created FLINK-37636: -- Summary: Weekly CI failure Key: FLINK-37636 URL: https://issues.apache.org/jira/browse/FLINK-37636 Project: Flink Issue Type: Improvement Components:

Re: [VOTE] Release flink-connector-kafka v4.0.0, release candidate #1

2025-04-08 Thread Yanquan Lv
Hi, Arvid. Thanks for your efforts in this release. I noticed that this released version was compiled using JDK 17, and there is also flink-connector-elasticsearch[1] support for Flink 2.0 release, which is compiled using JDK 11. I checked the compiled version of Flink 2.0 release, which is also j

[jira] [Created] (FLINK-37635) Add Docker Sql Gateway support

2025-04-08 Thread yuanfenghu (Jira)
yuanfenghu created FLINK-37635: -- Summary: Add Docker Sql Gateway support Key: FLINK-37635 URL: https://issues.apache.org/jira/browse/FLINK-37635 Project: Flink Issue Type: Improvement

Re: [VOTE] Release flink-connector-elasticsearch v3.1.0, release candidate #1

2025-04-08 Thread Yanquan Lv
I checked: - Review JIRA release notes - Verify hashes and verify signatures - Build success from source with JDK11 & maven3.8.6 - Source code artifacts matching the current release - Read the announcement blog and LGTM I noticed that we have supported ElasticSearch8 in this release and provided t

Re: [VOTE] Release flink-connector-kafka v4.0.0, release candidate #1

2025-04-08 Thread Hongshun Wang
Hi Heise Should we update NOTICE[1] to 2025 before release? [1] https://github.com/apache/flink-connector-kafka/blob/main/NOTICE Best Hongshun

Re: [ANNOUNCE] New Apache Flink PMC Member - Sergey Nuyanzin

2025-04-08 Thread Yanquan Lv
Congrations, Sergey! Best, Yanquan > 2025年4月3日 14:54,Dawid Wysakowicz 写道: > > On behalf of the PMC, I'm very happy to announce a new Apache Flink PMC > Member > - Sergey Nuyanzin. > > Sergey has been a dedicated and invaluable contributor to the Flink > community for several years. He became a

[jira] [Created] (FLINK-37634) When the table name of mysql supports size sensitive, an error occurred when the table name of alter capitalization will not be found.

2025-04-08 Thread Jira
林健昌 created FLINK-37634: --- Summary: When the table name of mysql supports size sensitive, an error occurred when the table name of alter capitalization will not be found. Key: FLINK-37634 URL: https://issues.apache.org/jira/

[VOTE] Release flink-connector-kafka v4.0.0, release candidate #1

2025-04-08 Thread Arvid Heise
Hi everyone, Please review and vote on release candidate #1 for flink-connector-kafka v4.0.0, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) The complete staging area is available for your review, which includes: * JIRA release notes

GSoC 2025 Applicant Introduction – Jay Rakesh Sharma

2025-04-08 Thread Jay Sharma
Hi Apache Flink community, I'm Jay Rakesh Sharma, a GSoC 2025 applicant. I’ve submitted a proposal focused on enhancing Flink’s rule-based logic processing using Java. With a background in mathematics and computer applications, I’m eager to contribute to Flink’s powerful stream processing engine a

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

2025-04-08 Thread Őrhidi Mátyás
Thanks, Yanquan. We can also introduce some restart/recovery strategies on how to handle MDS unavailability. On Sat, Apr 5, 2025 at 10:57 PM Yanquan Lv wrote: > Your explanation is helpful. > > For question3, I think the key lies in whether the situation where MDS is > unavailable is considered

Re: Kafka connector 4.0.0 release

2025-04-08 Thread Ferenc Csaky
+1 for the release and the release manager. Thanks for driving this. Best, Ferenc On Tuesday, April 8th, 2025 at 05:06, Leonard Xu wrote: > > > +1, thanks @Arvid for driving this release! > > Best, > Leonard > > > 2025 4月 7 18:02,Tom Cooper c...@tomcooper.dev 写道: > > > > +1 from me. Than

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

2025-04-08 Thread Alexander Fedulov
+1 (binding) Best, Alex On Mon, 7 Apr 2025 at 18:26, Maximilian Michels wrote: > +1 (binding) > > Cheers, > Max > > On Thu, Apr 3, 2025 at 2:04 PM Gabor Somogyi > wrote: > > > > +1 (binding) > > > > BR, > > G > > > > > > On Thu, Apr 3, 2025 at 11:49 AM wrote: > > > > > +1 (binding) > > > > >

Re: [DISCUSS] FLIP-Draft - Amazon CloudWatch Metric Sink Connector

2025-04-08 Thread Hong Liang
Hi Daren, Thanks for the contribution — exciting to see support for new sinks! I’ve added a few comments and suggestions below: 1. Clarify Cloudwatch API limitations and handling in the sink. [1] Great to see we're being explicit with the Java API model! Let's be explicit about the PutMetricsData

[jira] [Created] (FLINK-37633) Improved state management for temporal join operator

2025-04-08 Thread Hugo Ricateau (Jira)
Hugo Ricateau created FLINK-37633: - Summary: Improved state management for temporal join operator Key: FLINK-37633 URL: https://issues.apache.org/jira/browse/FLINK-37633 Project: Flink Issue

[jira] [Created] (FLINK-37632) Add ChangelogFunction interface

2025-04-08 Thread Timo Walther (Jira)
Timo Walther created FLINK-37632: Summary: Add ChangelogFunction interface Key: FLINK-37632 URL: https://issues.apache.org/jira/browse/FLINK-37632 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37630) Support flink cdc pipeline Yarn session mode

2025-04-08 Thread ouyangwulin (Jira)
ouyangwulin created FLINK-37630: --- Summary: Support flink cdc pipeline Yarn session mode Key: FLINK-37630 URL: https://issues.apache.org/jira/browse/FLINK-37630 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-37631) Support flink cdc pipeline k session mode

2025-04-08 Thread ouyangwulin (Jira)
ouyangwulin created FLINK-37631: --- Summary: Support flink cdc pipeline k session mode Key: FLINK-37631 URL: https://issues.apache.org/jira/browse/FLINK-37631 Project: Flink Issue Type: Improveme

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

2025-04-08 Thread Leonard Xu
Hi @Matyas, First of all, apologies for jumping into the vote thread. Could you kindly reply to Hongshun’s question in the discussion thread when you have a moment? Additionally, I have a question regarding the KafkaMetadataServiceImpl class mentioned in your proposed Public Interface. I revisi

Re: [ANNOUNCE] New Apache Flink PMC Member - Sergey Nuyanzin

2025-04-08 Thread Feifan Wang
Congratulations Sergey! —— Best regards, Feifan Wang Replied Message | From | Hong Liang | | Date | 04/8/2025 03:26 | | To | | | Subject | Re: [ANNOUNCE] New Apache Flink PMC Member - Sergey Nuyanzin | Congratulations Sergey! Well deserved. Hong On Mon, Apr 7, 2025 a