Re: [DISCUSS] FLIP-XXX: Aligning timeout logic in the AdaptiveScheduler's WaitingForResources and Executing states

2024-08-05 Thread Rui Fan
Thanks Zdenek for the quick response and update! +1 for this FLIP. Best, Rui On Mon, Aug 5, 2024 at 2:56 PM Zdenek Tison wrote: > Hi Rui, > > Yes, it's right. > We will update the FLIP's parameters table to make it more explicit. > > Thanks > > Best, > Zdenek > > On Mon, Aug 5, 2024 at 5:33 AM

Re: [DISCUSS] FLIP-XXX: Aligning timeout logic in the AdaptiveScheduler's WaitingForResources and Executing states

2024-08-05 Thread Matthias Pohl
Ok, I went ahead and updated the FLIP accordingly [1]. [1] https://cwiki.apache.org/confluence/pages/diffpagesbyversion.action?pageId=315494203&selectedPageVersions=7&selectedPageVersions=5 On Mon, Aug 5, 2024 at 8:56 AM Zdenek Tison wrote: > Hi Rui, > > Yes, it's right. > We will update the FL

[VOTE] FLIP-472: Aligning timeout logic in the AdaptiveScheduler's WaitingForResources and Executing states

2024-08-05 Thread Zdenek Tison
Hi everyone, Thanks for all the feedback about FLIP-472: Aligning timeout logic in the AdaptiveScheduler's WaitingForResources and Executing states [1]. The discussion thread can be found here [2]. The vote will be open for at least 72 hours unless there are any objections or insufficient vote

Re: [VOTE] FLIP-472: Aligning timeout logic in the AdaptiveScheduler's WaitingForResources and Executing states

2024-08-05 Thread Rui Fan
+1(binding) Best, Rui On Mon, Aug 5, 2024 at 3:11 PM Zdenek Tison wrote: > Hi everyone, > > > Thanks for all the feedback about FLIP-472: Aligning timeout logic in the > AdaptiveScheduler's WaitingForResources and Executing states [1]. The > discussion thread can be found here [2]. > > > The vo

[jira] [Created] (FLINK-35976) StreamPhysicalOverAggregate should handle column name confliction

2024-08-05 Thread lincoln lee (Jira)
lincoln lee created FLINK-35976: --- Summary: StreamPhysicalOverAggregate should handle column name confliction Key: FLINK-35976 URL: https://issues.apache.org/jira/browse/FLINK-35976 Project: Flink

Re: [VOTE] FLIP-472: Aligning timeout logic in the AdaptiveScheduler's WaitingForResources and Executing states

2024-08-05 Thread yuanfeng hu
+1 (no-binding) Rui Fan <1996fan...@gmail.com> 于2024年8月5日周一 15:18写道: > +1(binding) > > Best, > Rui > > On Mon, Aug 5, 2024 at 3:11 PM Zdenek Tison > wrote: > > > Hi everyone, > > > > > > Thanks for all the feedback about FLIP-472: Aligning timeout logic in the > > AdaptiveScheduler's WaitingForR

Re: [DISCUSS] FLIP-XXX: Aligning timeout logic in the AdaptiveScheduler's WaitingForResources and Executing states

2024-08-05 Thread Zdenek Tison
Thanks everyone for your feedback. Since there were no open questions, we have started voting [1]. Best, Zdenek [1] https://lists.apache.org/thread/3yod1cf06qxf5jny0hrbcxp33tlp7vs6 On Mon, Aug 5, 2024 at 9:03 AM Matthias Pohl wrote: > Ok, I went ahead and updated the FLIP accordingly [1]. > >

Re: [DISCUSS] FLIP-455: Declare async state processing and checkpoint the in-flight requests

2024-08-05 Thread Piotr Nowojski
Hi Zakelly, Thanks for driving this! I also have a couple of questions. But overall the proposal LGTM. >> 2. Besides `processElement`, there are other methods that access state, >> such as >> `snapshotState`. Are these methods also not applicable under this FLIP? > > Well the async state APIs are

Re: [VOTE] FLIP-471: Fixing watermark idleness timeout accounting

2024-08-05 Thread Piotr Nowojski
The voting period is closed. Thank you all for voting. Best, Piotrek pt., 2 sie 2024 o 14:58 Roman Khachatryan napisał(a): > +1 (binding) > > Regards, > Roman > > > On Wed, Jul 31, 2024 at 2:39 PM Rui Fan <1996fan...@gmail.com> wrote: > > > +1(binding) > > > > Best, > > Rui > > > > Timo Walther

[RESULT][VOTE] FLIP-471: Fixing watermark idleness timeout accounting

2024-08-05 Thread Piotr Nowojski
Hi all! The FLIP-471 [1] has been accepted in the voting thread [2]. There were 6 binding votes in favour: - Zakelly Lan - Stefan Richter - Timo Walther - Rui Fan - Roman Khachatryan - Piotr Nowojski zero against. Best, Piotrek [1] https://cwiki.apache.org/confluence/x/oQvOEg [2] https://lists.

Re: [VOTE] FLIP-472: Aligning timeout logic in the AdaptiveScheduler's WaitingForResources and Executing states

2024-08-05 Thread David Morávek
+1 (binding) Best, D. On Mon, Aug 5, 2024 at 9:24 AM yuanfeng hu wrote: > +1 (no-binding) > > Rui Fan <1996fan...@gmail.com> 于2024年8月5日周一 15:18写道: > > > +1(binding) > > > > Best, > > Rui > > > > On Mon, Aug 5, 2024 at 3:11 PM Zdenek Tison > > > wrote: > > > > > Hi everyone, > > > > > > > > > T

Re: Discussion on Vertica-Flink Connector

2024-08-05 Thread Ahmed Hamdy
Hi Vikas, Could you address feedback from Yanquan, we can create the FLIP page later. Best Regards Ahmed Hamdy On Mon, 5 Aug 2024 at 07:17, Vikas Garg wrote: > Hello, > > We are looking forward to creating FLIP for voting. Can someone help me > with creating the FLIP since now we don't have ac

[jira] [Created] (FLINK-35977) Missing an import in datastream.md

2024-08-05 Thread guluo (Jira)
guluo created FLINK-35977: - Summary: Missing an import in datastream.md Key: FLINK-35977 URL: https://issues.apache.org/jira/browse/FLINK-35977 Project: Flink Issue Type: Bug Affects Versions: 1.

[jira] [Created] (FLINK-35978) adapt labelling of boring cyborg

2024-08-05 Thread Jira
João Boto created FLINK-35978: - Summary: adapt labelling of boring cyborg Key: FLINK-35978 URL: https://issues.apache.org/jira/browse/FLINK-35978 Project: Flink Issue Type: Sub-task R

[jira] [Created] (FLINK-35979) Add flink version 2.0-SNAPSHOT to ci

2024-08-05 Thread Jira
João Boto created FLINK-35979: - Summary: Add flink version 2.0-SNAPSHOT to ci Key: FLINK-35979 URL: https://issues.apache.org/jira/browse/FLINK-35979 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-35980) Add transform test coverage in Integrated / E2e tests

2024-08-05 Thread yux (Jira)
yux created FLINK-35980: --- Summary: Add transform test coverage in Integrated / E2e tests Key: FLINK-35980 URL: https://issues.apache.org/jira/browse/FLINK-35980 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35981) Transform rule doesn't support referencing one column more than once

2024-08-05 Thread yux (Jira)
yux created FLINK-35981: --- Summary: Transform rule doesn't support referencing one column more than once Key: FLINK-35981 URL: https://issues.apache.org/jira/browse/FLINK-35981 Project: Flink Issue Typ

[jira] [Created] (FLINK-35982) Transform metadata config doesn't work if no projection block was provided

2024-08-05 Thread yux (Jira)
yux created FLINK-35982: --- Summary: Transform metadata config doesn't work if no projection block was provided Key: FLINK-35982 URL: https://issues.apache.org/jira/browse/FLINK-35982 Project: Flink Iss

[jira] [Created] (FLINK-35983) Job crashes when using wildcard (*) match with metadata column

2024-08-05 Thread yux (Jira)
yux created FLINK-35983: --- Summary: Job crashes when using wildcard (*) match with metadata column Key: FLINK-35983 URL: https://issues.apache.org/jira/browse/FLINK-35983 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35984) Job crashes when metadata column names present in transform rules

2024-08-05 Thread yux (Jira)
yux created FLINK-35984: --- Summary: Job crashes when metadata column names present in transform rules Key: FLINK-35984 URL: https://issues.apache.org/jira/browse/FLINK-35984 Project: Flink Issue Type:

Re: [DISCUSS] FLIP-455: Declare async state processing and checkpoint the in-flight requests

2024-08-05 Thread Zakelly Lan
Hi Piotr, Thanks for your comments! PTAL at my answers: AFAIU it means async state requests can be used basically everywhere, but > unless > they are coming from declaring process in process elements/timers, they > won't be > interruptible and will have to be drained before checkpoint commences?

[jira] [Created] (FLINK-35985) SUBSTRING function not available in transform rules

2024-08-05 Thread yux (Jira)
yux created FLINK-35985: --- Summary: SUBSTRING function not available in transform rules Key: FLINK-35985 URL: https://issues.apache.org/jira/browse/FLINK-35985 Project: Flink Issue Type: Bug C

[jira] [Created] (FLINK-35986) NULL literal is not supported in Transform rules

2024-08-05 Thread yux (Jira)
yux created FLINK-35986: --- Summary: NULL literal is not supported in Transform rules Key: FLINK-35986 URL: https://issues.apache.org/jira/browse/FLINK-35986 Project: Flink Issue Type: Bug Comp

[jira] [Created] (FLINK-35987) Add ELT function

2024-08-05 Thread Dylan He (Jira)
Dylan He created FLINK-35987: Summary: Add ELT function Key: FLINK-35987 URL: https://issues.apache.org/jira/browse/FLINK-35987 Project: Flink Issue Type: Sub-task Components: Table SQL