[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