Re: [VOTE] FLIP-524: CloudWatch Metric Sink Connector

2025-04-21 Thread Ferenc Csaky
+1 (binding) Thanks for driving this! On Friday, April 18th, 2025 at 16:57, Robert Metzger wrote: > > > +1 (binding) > > On Wed, Apr 16, 2025 at 10:39 AM Daren Wong darenwkt@gmail.com wrote: > > > Hi devs, > > > > Thank you everyone for the feedback on FLIP-524: CloudWatch Metric Sin

[jira] [Created] (FLINK-37712) Table

2025-04-21 Thread Yanquan Lv (Jira)
Yanquan Lv created FLINK-37712: -- Summary: Table Key: FLINK-37712 URL: https://issues.apache.org/jira/browse/FLINK-37712 Project: Flink Issue Type: Bug Reporter: Yanquan Lv -- T

[jira] [Created] (FLINK-37711) Remove unused getJobGraph from PipelineExecutorUtils

2025-04-21 Thread Jiaan Geng (Jira)
Jiaan Geng created FLINK-37711: -- Summary: Remove unused getJobGraph from PipelineExecutorUtils Key: FLINK-37711 URL: https://issues.apache.org/jira/browse/FLINK-37711 Project: Flink Issue Type:

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

2025-04-21 Thread Yanquan Lv
Gentle ping for more binding votes. Tom Cooper 于2025年4月17日周四 20:09写道: > Hi Arvid, > > Thanks for looking at this. I can confirm that updated sources now compile > on my Fedora box. I still get the following warning when running tar -xf: > > tar: Ignoring unknown extended header keyword > 'LIBARC

[jira] [Created] (FLINK-37710) Schema operator relies on data sources re-emitting CreateTableEvents during startup

2025-04-21 Thread Sergei Morozov (Jira)
Sergei Morozov created FLINK-37710: -- Summary: Schema operator relies on data sources re-emitting CreateTableEvents during startup Key: FLINK-37710 URL: https://issues.apache.org/jira/browse/FLINK-37710

Order of OperatorCoordinator method calls

2025-04-21 Thread Sergei Morozov
Hi, I'm observing a behavior in Flink 1.20.0 that contradicts the documentation. The JavaDoc for OperatorCoordinator#start() says: This method is called once at the beginning, before any other methods. However, I see that OperatorCoordinator#resetToCheckpoint() is called even before start(), as

[jira] [Created] (FLINK-37709) Add file descriptor usage in default JVM metrics

2025-04-21 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-37709: - Summary: Add file descriptor usage in default JVM metrics Key: FLINK-37709 URL: https://issues.apache.org/jira/browse/FLINK-37709 Project: Flink Issue Typ

RE: [VOTE] FLIP-524: CloudWatch Metric Sink Connector

2025-04-21 Thread Dhingra, Priya
+1(non-binding) On 2025/04/16 08:37:58 Daren Wong wrote: > Hi devs, > > Thank you everyone for the feedback on FLIP-524: CloudWatch Metric Sink > Connector > https://cwiki.apache.org/confluence/display/FLINK/FLIP-524:+CloudWatch+Metric+Sink+Connector. > > I would like to start a vote for it. The

回复: [DISCUSS] Drop support for HBase v1

2025-04-21 Thread tanjialiang
Hi Martijn, Ferenc Thanks all for driving this. As Ferenc said, HBase 1.x is dead, so on the way forward it should be safe to drop it. Same view as mine. So +1 for this. Best! tanjialiang 发件人: Ferenc Csaky 发送时间: 2024年1月30日 22:14 收件人: dev@flink.apache.org 主题: Re: [DISCUSS] Drop support for HBase

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

2025-04-21 Thread Yuepeng Pan
+1 (non-binding) Checked: - Download links. - Local build from source with JDK 11 - Verified the test cases. Best Regards, Yuepeng At 2025-04-21 19:46:03, "Zakelly Lan" wrote: >+1 (binding) > >I have verified: > > - Checksum and signature > - Github CI > - There are no binaries

Re: [VOTE] FLIP-522: Add generalized type information to SQL state connector

2025-04-21 Thread Őrhidi Mátyás
+1 (binding) On Mon, Apr 21, 2025 at 3:32 AM Zakelly Lan wrote: > +1 (binding) > > > Best, > Zakelly > > On Mon, Apr 21, 2025 at 6:17 PM Márton Balassi > wrote: > > > +1 (binding) > > > > On Mon, Apr 21, 2025 at 9:27 AM Gabor Somogyi > > > wrote: > > > > > Hi All, > > > > > > I'd like to start

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

2025-04-21 Thread Zakelly Lan
+1 (binding) I have verified: - Checksum and signature - Github CI - There are no binaries in the source archive - Release tag and staging jars, manifest shows they are built by JDK 11.0.16.1 - Release notes and web PR Best, Zakelly On Mon, Apr 21, 2025 at 4:28 PM Xiqian YU wrote: > +1

Re: [VOTE] Release flink-connector-jdbc v3.3.0, release candidate #2

2025-04-21 Thread Zakelly Lan
+1 (binding) I have verified: - Checksum and signature - Github CI - There are no binaries in the source archive - Release tag and staging jars, manifest shows they are built by JDK 1.8.0_301 - Release notes and web PR Best, Zakelly On Mon, Apr 21, 2025 at 3:54 PM weijie guo wrote: > +1

[jira] [Created] (FLINK-37708) Print digest about SinkAbilitySpec in plan just like SourceAbilitySpec

2025-04-21 Thread Xuyang Zhong (Jira)
Xuyang Zhong created FLINK-37708: Summary: Print digest about SinkAbilitySpec in plan just like SourceAbilitySpec Key: FLINK-37708 URL: https://issues.apache.org/jira/browse/FLINK-37708 Project: Flink

Re: [VOTE] FLIP-522: Add generalized type information to SQL state connector

2025-04-21 Thread Zakelly Lan
+1 (binding) Best, Zakelly On Mon, Apr 21, 2025 at 6:17 PM Márton Balassi wrote: > +1 (binding) > > On Mon, Apr 21, 2025 at 9:27 AM Gabor Somogyi > wrote: > > > Hi All, > > > > I'd like to start a vote on FLIP-522: Add generalized type information to > > SQL state connector [1] > > which has

Re: [DISCUSS] Missing TreeMapState abstraction for maintaining ordered state

2025-04-21 Thread Zakelly Lan
Hi Charles, Thanks for the summary. Yeah it is what has been discussed so far. Note 1: From what I understand (I haven’t looked into Flink’s internals > yet), the proposed encoding should be compatible with ForSt as well. > ForSt shares almost the same encoding as RocksDB (in serialized bytes).

Re: [VOTE] FLIP-522: Add generalized type information to SQL state connector

2025-04-21 Thread Márton Balassi
+1 (binding) On Mon, Apr 21, 2025 at 9:27 AM Gabor Somogyi wrote: > Hi All, > > I'd like to start a vote on FLIP-522: Add generalized type information to > SQL state connector [1] > which has been discussed in this thread [2]. > > The vote will be open for at least 72 hours unless there is an ob

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

2025-04-21 Thread Daren Wong
Hi Robert, Thanks for the question, I took a look and agree with your latter point that it is not necessary as Flink StatsD metrics reporter works with CloudWatch Agent StatsD interface. Regards, Daren > On 18 Apr 2025, at 15:57, Robert Metzger wrote: > > Hi, > quick, somewhat related questi

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

2025-04-21 Thread Xiqian YU
+1 (non-binding) Checklist: - verified that checksum and gig signatures are valid - confirmed jar codes were built with JDK 11.0.16.1 and Apache Maven 3.8.6, bytecode version is 55.0 - built source code successfully with JDK 11 and 17 - confirmed that test cases & compatibility tests all passed

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

2025-04-21 Thread weijie guo
+1(binding) - verified signatures and hashsums - checked github tag - checked release notes - built from source. Best regards, Weijie Leonard Xu 于2025年4月21日周一 14:54写道: > +1 (binding) > > - built from source code succeeded > - verified signatures > - verified hashsums > - checked Github relea

Re: [VOTE] Release flink-connector-jdbc v3.3.0, release candidate #2

2025-04-21 Thread weijie guo
+1(binding) - verified signatures and hashsums - checked release tag - checked release notes - built from source Best regards, Weijie Leonard Xu 于2025年4月21日周一 15:30写道: > +1 (binding) > > - built from source code with Java 8 succeeded > - verified signatures > - verified hashsums > - checked

[jira] [Created] (FLINK-37707) Deprecate DeserializationSchema#deserialize(byte[])

2025-04-21 Thread Hongjia Liang (Jira)
Hongjia Liang created FLINK-37707: - Summary: Deprecate DeserializationSchema#deserialize(byte[]) Key: FLINK-37707 URL: https://issues.apache.org/jira/browse/FLINK-37707 Project: Flink Issue

Re: [VOTE] Release flink-connector-jdbc v3.3.0, release candidate #2

2025-04-21 Thread Leonard Xu
+1 (binding) - built from source code with Java 8 succeeded - verified signatures - verified hashsums - checked Github release tag - checked release notes - reviewed the web PR - checked the failed test in RC2 has been fixed - checked the jar was built by JDK 8 version 52.0 (Java 1.8) Best, L

[VOTE] FLIP-522: Add generalized type information to SQL state connector

2025-04-21 Thread Gabor Somogyi
Hi All, I'd like to start a vote on FLIP-522: Add generalized type information to SQL state connector [1] which has been discussed in this thread [2]. The vote will be open for at least 72 hours unless there is an objection or not enough votes are casted. [1] https://cwiki.apache.org/confluence/

Re: [ANNOUNCE] New Apache Flink Committer - Xiqian Yu

2025-04-21 Thread yunhong Zheng
Congratulations! Best Yunhong (SwuferHong) Feng Jin 于2025年4月18日周五 14:57写道: > Congratulations! > > Best, > Feng Jin > > On Fri, Apr 18, 2025 at 2:13 PM Sergey Nuyanzin > wrote: > > > Congratulations! > > > > On Fri, Apr 18, 2025, 06:00 Hang Ruan wrote: > > > > > Congratulations! > > > > > > Be

Re: [ANNOUNCE] New Apache Flink Committer - Yanquan Lv

2025-04-21 Thread yunhong Zheng
Congratulations! Best Yunhong (SwuferHong) Feng Jin 于2025年4月18日周五 14:57写道: > Congratulations! > > Best, > Feng Jin > > On Fri, Apr 18, 2025 at 2:13 PM Sergey Nuyanzin > wrote: > > > Congratulations! > > > > On Fri, Apr 18, 2025, 05:59 Hang Ruan wrote: > > > > > Congrats Yanquan! > > > > > > B