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

2025-06-27 Thread Keith Lee
chive does not contain binary 4. Source archive is signed with *125FD8DB *instead of B78A5EA1 5. Checked that all poms point to version 5.1.0-1.20 6. Checked that pom key is signed with *B78A5EA1* Best regards Keith Lee On Fri, Jun 27, 2025 at 4:44 PM Keith Lee wrote: > +1, thank you Daren,

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

2025-06-27 Thread Keith Lee
ary 4. Source archive is signed with *125FD8DB* instead of B78A5EA1 5. Checked that all poms point to version 6.0.0 6. Checked that pom key is signed with B78A5EA1 7. Checked licenses. Best regards Keith Lee On Fri, Jun 27, 2025 at 4:44 PM Keith Lee wrote: > +1, thank you Daren, Hong a

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

2025-06-27 Thread Keith Lee
+1, thank you Daren, Hong and Danny! Best regards Keith Lee On Fri, Jun 27, 2025 at 2:23 PM Daren Wong wrote: > Hi everyone, > Please review and vote on release candidate #1 for flink-connector-aws > v6.0.0, as follows: > [ ] +1, Approve the release > [ ] -1, Do not appr

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

2025-06-27 Thread Keith Lee
+1, thank you Daren, Hong and Danny! Best regards Keith Lee On Fri, Jun 27, 2025 at 2:22 PM Daren Wong wrote: > Hi everyone, > Please review and vote on release candidate #1 for flink-connector-aws > v5.1.0, as follows: > [ ] +1, Approve the release > [ ] -1, Do not appr

[jira] [Created] (FLINK-37949) FlinkKinesisConsumer on EFO mode runs into Netty deadlock on client close during stop-with-savepoint

2025-06-12 Thread Keith Lee (Jira)
Keith Lee created FLINK-37949: - Summary: FlinkKinesisConsumer on EFO mode runs into Netty deadlock on client close during stop-with-savepoint Key: FLINK-37949 URL: https://issues.apache.org/jira/browse/FLINK-37949

[jira] [Created] (FLINK-37808) Checkpoint completed after job failure

2025-05-15 Thread Keith Lee (Jira)
Keith Lee created FLINK-37808: - Summary: Checkpoint completed after job failure Key: FLINK-37808 URL: https://issues.apache.org/jira/browse/FLINK-37808 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-37687) Bump flink-connector-aws to 2.0

2025-04-16 Thread Keith Lee (Jira)
Keith Lee created FLINK-37687: - Summary: Bump flink-connector-aws to 2.0 Key: FLINK-37687 URL: https://issues.apache.org/jira/browse/FLINK-37687 Project: Flink Issue Type: Bug

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

2025-04-14 Thread Keith Lee
tched based on maxBatchSize which is then submitted as a PutMetricDataRequest. 5. On the batching of requests, how do you propose batch size (specifically size) is enforced? Specifically, I am interested in how we are calculating the data sizes of a batch. Best regards Keith Lee On Fri, Apr 11, 2

[jira] [Created] (FLINK-37627) Restarting from a checkpoint/savepoint which coincides with shard split causes data loss

2025-04-07 Thread Keith Lee (Jira)
Keith Lee created FLINK-37627: - Summary: Restarting from a checkpoint/savepoint which coincides with shard split causes data loss Key: FLINK-37627 URL: https://issues.apache.org/jira/browse/FLINK-37627

[jira] [Created] (FLINK-36939) High CPU Utilization with Flink Kinesis EFO Consumer

2024-12-19 Thread Keith Lee (Jira)
Keith Lee created FLINK-36939: - Summary: High CPU Utilization with Flink Kinesis EFO Consumer Key: FLINK-36939 URL: https://issues.apache.org/jira/browse/FLINK-36939 Project: Flink Issue Type

[jira] [Created] (FLINK-36155) ByteBuf.release() was not called before it's garbage-collected

2024-08-26 Thread Keith Lee (Jira)
Keith Lee created FLINK-36155: - Summary: ByteBuf.release() was not called before it's garbage-collected Key: FLINK-36155 URL: https://issues.apache.org/jira/browse/FLINK-36155 Project:

[jira] [Created] (FLINK-35853) Regression in checkpoint size when performing full checkpointing in RocksDB

2024-07-16 Thread Keith Lee (Jira)
Keith Lee created FLINK-35853: - Summary: Regression in checkpoint size when performing full checkpointing in RocksDB Key: FLINK-35853 URL: https://issues.apache.org/jira/browse/FLINK-35853 Project: Flink

Re: [VOTE] FLIP-444: Native file copy support

2024-06-26 Thread Keith Lee
+1 (non binding) Best regards Keith Lee On Wed, Jun 26, 2024 at 9:48 AM Zakelly Lan wrote: > +1 (binding) > > > Best, > Zakelly > > On Wed, Jun 26, 2024 at 3:54 PM Yuepeng Pan wrote: > > > +1 (non-binding) > > > > >

Re: [DISCUSS] FLIP-444: Native file copy support

2024-06-18 Thread Keith Lee
very useful for users who may want to implement said limiting. Best regards Keith Lee On Mon, Jun 17, 2024 at 5:50 PM Piotr Nowojski wrote: > Hi all! > > >> Do you know if there is a way to limit the CPU utilisation of s5cmd? I > see > >> worker and concurrency configura

Re: [DISCUSS] FLIP-444: Native file copy support

2024-06-18 Thread Keith Lee
I meant to address Piotr on the above, apologies! Best regards Keith Lee On Tue, Jun 18, 2024 at 8:06 AM Keith Lee wrote: > Hi Lorenzo, > > > As I mentioned above, in the end I think hardcoding in Flink support for > the `cpulimit` doesn't seem appropriate and at the

Re: [DISCUSS] FLIP-XXX: Improve JDBC connector extensibility for Table API

2024-05-21 Thread Keith Lee
that. Can you provide other example configuration (actual examples for MySQL/Postgres etc. would be great) that may illustrate the usefulness of the proposal better? Best regards Keith Lee On Tue, May 21, 2024 at 2:01 PM Leonard Xu wrote: > Thanks Lorenzo for kicking off this discussion. >

Re: [DISCUSS] FLINK-35369: Improve `Table API and SQL` page or add new page to guide new users to right Flink SQL option

2024-05-16 Thread Keith Lee
, should FLIP criteria [1] be updated so that reorganisation of public documentation fall under it as well? Best regards Keith Lee [1] https://cwiki.apache.org/confluence/plugins/servlet/mobile?contentId=65145551#FlinkImprovementProposals-Whatisconsidereda%22majorchange%22thatneedsaFLIP? On Thu

[DISCUSS] FLINK-35369: Improve `Table API and SQL` page or add new page to guide new users to right Flink SQL option

2024-05-15 Thread Keith Lee
me. https://issues.apache.org/jira/browse/FLINK-35369 Appreciate your thoughts and suggestions. Best regards Keith Lee

[jira] [Created] (FLINK-35369) Improve `Table API and SQL` page or add new page to guide new users to right Flink SQL option

2024-05-15 Thread Keith Lee (Jira)
Keith Lee created FLINK-35369: - Summary: Improve `Table API and SQL` page or add new page to guide new users to right Flink SQL option Key: FLINK-35369 URL: https://issues.apache.org/jira/browse/FLINK-35369

Re: [jira] [Updated] (FLINK-35336) SQL failed to restore from savepoint after change in default-parallelism

2024-05-13 Thread Keith Lee
restore after Flink statement changes. How best should such a feature request be driven? Will a FLIP be necessary? Best regards Keith Lee On Mon, May 13, 2024 at 1:27 PM Martijn Visser (Jira) wrote: > > [ > https://issues.apache.org/jira/browse/FLINK-3

Re: [jira] [Created] (FLINK-35336) SQL failed to restore from savepoint after change in default-parallelismFlink/Flink:User

2024-05-13 Thread Keith Lee
the effort to fix the bug. Best regards Keith Lee On Mon, May 13, 2024 at 11:37 AM Keith Lee (Jira) wrote: > Keith Lee created FLINK-35336: > - > > Summary: SQL failed to restore from savepoint after change in > default-parallelismF

[jira] [Created] (FLINK-35336) SQL failed to restore from savepoint after change in default-parallelismFlink/Flink:User

2024-05-13 Thread Keith Lee (Jira)
Keith Lee created FLINK-35336: - Summary: SQL failed to restore from savepoint after change in default-parallelismFlink/Flink:User Key: FLINK-35336 URL: https://issues.apache.org/jira/browse/FLINK-35336

Re: Re: [VOTE] FLIP-448: Introduce Pluggable Workflow Scheduler Interface for Materialized Table

2024-05-11 Thread Keith Lee
+1 (non-binding) Best regards Keith Lee On Sat, 11 May 2024 at 04:58, Shengkai Fang wrote: > +1 (binding) > > Best, > Shengkai > > Ron Liu 于2024年5月10日周五 12:07写道: > > > +1(binding) > > > > Best, > > Ron > > > > Jark Wu 于2024

Re: [DISCUSS] FLIP-444: Native file copy support

2024-05-09 Thread Keith Lee
Hi Piotr, Thank you for the proposal. Looks great. Along similar line of Aleks' question on memory usage. The proposal mentions that s5cmd utilises 100% of CPU similar to Flink 1.18. However, this will be a native process outside of the JVM. Are there risk of large/long state download starving t

Re: [VOTE] FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0

2024-05-09 Thread Keith Lee
+1 (non-binding) Great work on the benchmark data. Keith On Thu, May 9, 2024 at 4:53 AM 周仁祥 wrote: > +1 (non-binding) > > ConradJam 于2024年5月7日周二 11:35写道: > > > +1 (no-binding) > > > > Piotr Nowojski 于2024年5月6日周一 20:17写道: > > > > > +1 (binding) > > > > > > Piotrek > > > > > > pon., 6 maj 2024