Re: [ANNOUNCE] The Flink Speed Center and benchmark daily run are back online

2023-10-19 Thread Leonard Xu
Thanks Zakelly for the great work. Best, Leonard > 2023年10月19日 下午7:39,Jing Ge 写道: > > Hi Zakelly, > > Thank you for your effort! Really appreciate it! > > Best regards, > Jing > > On Thu, Oct 19, 2023 at 12:02 PM Yun Tang wrote: > >> Thanks for Zakelly's great work! >> >> >> Best >> Yun

Re:[DISCUSS] FLIP-370 : Support Balanced Tasks Scheduling

2023-10-19 Thread Yuepeng Pan
Hi, dev. After reviewing the entire email discussion thread with Rui, I noticed that my previous ambiguous understanding led to a few incorrect conclusions. So I need to change the corresponding conclusions. And Thanks for the help from Rui. >For David: >The problem you're trying to s

[jira] [Created] (FLINK-33322) ProjectWatermarkAssignerTransposeRule support nested nested projection push down in transpose

2023-10-19 Thread lijingwei (Jira)
lijingwei created FLINK-33322: - Summary: ProjectWatermarkAssignerTransposeRule support nested nested projection push down in transpose Key: FLINK-33322 URL: https://issues.apache.org/jira/browse/FLINK-33322

Re: [DISCUSS] FLIP-329: Add operator attribute to specify support for object-reuse

2023-10-19 Thread Ken Krugler
Hi Dong, Sorry for not seeing this initially. I did have one question about the description of the issue in the FLIP: > However, in cases where the upstream and downstream operators do not store or > access references to the input or output records, this deep-copy overhead > becomes unnecessar

Re: [DISCUSS] Implementing SQL remote functions

2023-10-19 Thread Alan Sheinberg
Hi Feng, Krzysztof Sorry for the delayed response. FLIP-313 seems to be a good solution for the TableFunction use case. It would be nice to also have async support for ScalarFunction, AggregateFunction, and TableAggregateFunction too ideally, though this is a lot of work. ScalarFunction is real

[jira] [Created] (FLINK-33321) VertexFlameGraphFactoryTest#verifyRecursively fails on Java 21

2023-10-19 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-33321: --- Summary: VertexFlameGraphFactoryTest#verifyRecursively fails on Java 21 Key: FLINK-33321 URL: https://issues.apache.org/jira/browse/FLINK-33321 Project: Flink

[jira] [Created] (FLINK-33320) Support Dynamic Logger Level Adjustment

2023-10-19 Thread RocMarshal (Jira)
RocMarshal created FLINK-33320: -- Summary: Support Dynamic Logger Level Adjustment Key: FLINK-33320 URL: https://issues.apache.org/jira/browse/FLINK-33320 Project: Flink Issue Type: Improvement

Re: [VOTE] Release 1.18.0, release candidate #3

2023-10-19 Thread Piotr Nowojski
+1 (binding) Best, Piotrek czw., 19 paź 2023 o 09:55 Yun Tang napisał(a): > +1 (non-binding) > > > * Build from source code > * Verify the pre-built jar packages were built with JDK8 > * Verify FLIP-291 with a standalone cluster, and it works fine with > StateMachine example. > *

[jira] [Created] (FLINK-33319) Add AverageTime metric to measure delta change in GC time

2023-10-19 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-33319: -- Summary: Add AverageTime metric to measure delta change in GC time Key: FLINK-33319 URL: https://issues.apache.org/jira/browse/FLINK-33319 Project: Flink Issue T

[jira] [Created] (FLINK-33318) Create TimeMsPerSec metrics for each collector and add metrics across all collectors

2023-10-19 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-33318: -- Summary: Create TimeMsPerSec metrics for each collector and add metrics across all collectors Key: FLINK-33318 URL: https://issues.apache.org/jira/browse/FLINK-33318 Proj

Re: [ANNOUNCE] The Flink Speed Center and benchmark daily run are back online

2023-10-19 Thread Jing Ge
Hi Zakelly, Thank you for your effort! Really appreciate it! Best regards, Jing On Thu, Oct 19, 2023 at 12:02 PM Yun Tang wrote: > Thanks for Zakelly's great work! > > > Best > Yun Tang > > From: Piotr Nowojski > Sent: Thursday, October 19, 2023 17:56 > To: de

Re: [DISCUSS] FLIP-364: Improve the restart-strategy

2023-10-19 Thread Rui Fan
Hi Konstantin and Max, Thanks for your feedback! Sorry, I forgot to mention the default value of `restart-strategy.exponential-delay.max-attempts-before-reset-backoff`. Retrying forever sounds good to me, I have added it to the FLIP: The default value of `restart-strategy.exponential-delay.max-

Re: [DISCUSS] FLIP-364: Improve the restart-strategy

2023-10-19 Thread Maximilian Michels
Hey Rui, +1 for making exponential backoff the default. I agree with Konstantin that retrying forever is a good default for exponential backoff because oftentimes the issue will resolve eventually. The purpose of exponential backoff is precisely to continue to retry without causing too much load.

Re: [ANNOUNCE] The Flink Speed Center and benchmark daily run are back online

2023-10-19 Thread Yun Tang
Thanks for Zakelly's great work! Best Yun Tang From: Piotr Nowojski Sent: Thursday, October 19, 2023 17:56 To: dev@flink.apache.org Subject: Re: [ANNOUNCE] The Flink Speed Center and benchmark daily run are back online Thank you! czw., 19 paź 2023 o 11:31 Kon

Re: [ANNOUNCE] The Flink Speed Center and benchmark daily run are back online

2023-10-19 Thread Piotr Nowojski
Thank you! czw., 19 paź 2023 o 11:31 Konstantin Knauf napisał(a): > Thanks a lot for working on this! > > Am Do., 19. Okt. 2023 um 10:24 Uhr schrieb Zakelly Lan < > zakelly@gmail.com>: > > > Hi everyone, > > > > Flink benchmarks [1] generate daily performance reports in the Apache > > Flink

Re: [DISCUSS] FLIP-364: Improve the restart-strategy

2023-10-19 Thread Konstantin Knauf
Hi Rui, Thank you for this proposal and working on this. I also agree that exponential back off makes sense as a new default in general. I think restarting indefinitely (no max attempts) makes sense by default, though, but of course allowing users to change is valuable. So, overall +1. Cheers,

Re: [ANNOUNCE] The Flink Speed Center and benchmark daily run are back online

2023-10-19 Thread Konstantin Knauf
Thanks a lot for working on this! Am Do., 19. Okt. 2023 um 10:24 Uhr schrieb Zakelly Lan < zakelly@gmail.com>: > Hi everyone, > > Flink benchmarks [1] generate daily performance reports in the Apache > Flink slack channel (#flink-dev-benchmarks) to detect performance > regression [2]. Those b

[jira] [Created] (FLINK-33317) Add cleaning mechanism for StreamConfig#SERIALIZEDUDF

2023-10-19 Thread Rui Fan (Jira)
Rui Fan created FLINK-33317: --- Summary: Add cleaning mechanism for StreamConfig#SERIALIZEDUDF Key: FLINK-33317 URL: https://issues.apache.org/jira/browse/FLINK-33317 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-33316) Avoid unnecessary heavy getStreamOperatorFactory

2023-10-19 Thread Rui Fan (Jira)
Rui Fan created FLINK-33316: --- Summary: Avoid unnecessary heavy getStreamOperatorFactory Key: FLINK-33316 URL: https://issues.apache.org/jira/browse/FLINK-33316 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-33315) Optimize memory usage of large StreamOperator

2023-10-19 Thread Rui Fan (Jira)
Rui Fan created FLINK-33315: --- Summary: Optimize memory usage of large StreamOperator Key: FLINK-33315 URL: https://issues.apache.org/jira/browse/FLINK-33315 Project: Flink Issue Type: Improvement

[ANNOUNCE] The Flink Speed Center and benchmark daily run are back online

2023-10-19 Thread Zakelly Lan
Hi everyone, Flink benchmarks [1] generate daily performance reports in the Apache Flink slack channel (#flink-dev-benchmarks) to detect performance regression [2]. Those benchmarks previously were running on several machines donated and maintained by Ververica. Unfortunately, those machines were

[jira] [Created] (FLINK-33314) Fix the named parameter example in window tvf

2023-10-19 Thread lincoln lee (Jira)
lincoln lee created FLINK-33314: --- Summary: Fix the named parameter example in window tvf Key: FLINK-33314 URL: https://issues.apache.org/jira/browse/FLINK-33314 Project: Flink Issue Type: Impro

Re: [VOTE] Release 1.18.0, release candidate #3

2023-10-19 Thread Yun Tang
+1 (non-binding) * Build from source code * Verify the pre-built jar packages were built with JDK8 * Verify FLIP-291 with a standalone cluster, and it works fine with StateMachine example. * Checked the signature * Viewed the PRs. Best Yun Tang __

[jira] [Created] (FLINK-33313) RexNodeExtractor fails to extract conditions with binary literal

2023-10-19 Thread Dan Zou (Jira)
Dan Zou created FLINK-33313: --- Summary: RexNodeExtractor fails to extract conditions with binary literal Key: FLINK-33313 URL: https://issues.apache.org/jira/browse/FLINK-33313 Project: Flink Issue

Re: [VOTE] FLIP-328: Allow source operators to determine isProcessingBacklog based on watermark lag

2023-10-19 Thread Xuannan Su
Hi all, There is still a discussion ongoing. I will cancel the vote for now. Best Regards, Xuannan On Thu, Oct 19, 2023 at 2:08 PM Dong Lin wrote: > > Thanks for the FLIP! > > +1 (binding) > > On Wed, Oct 18, 2023 at 10:25 AM Xuannan Su wrote: > > > Hi all, > > > > We would like to start the v