Re: Re: [DISCUSS] FLIP-387: Support named parameters for functions and call procedures

Hi all, Thank you for the valuable input. Since there are no new objections or suggestions, I will open a voting thread in two days. Best, Feng On Thu, Dec 21, 2023 at 6:58 PM Benchao Li wrote: > I'm glad to hear that this is in your plan. Sorry that I overlooked > the PoC link in the FLIP

[jira] [Created] (FLINK-33971) Specifies whether to use HBase table that supports dynamic columns.

MOBIN created FLINK-33971: - Summary: Specifies whether to use HBase table that supports dynamic columns. Key: FLINK-33971 URL: https://issues.apache.org/jira/browse/FLINK-33971 Project: Flink Issue

Re: [ANNOUNCE] New Apache Flink Committer - Alexander Fedulov

Congratulations, Alex! Best, Hang Samrat Deb 于2024年1月3日周三 14:18写道： > Congratulations Alex >

RE: Re: [DISCUSS] FLIP-377: Support configuration to disable filter push down for Table/SQL Sources

Thanks Leonard for your reminder, The FLIP title has been changed as FLIP-377: Support fine-grained configuration to control filter push down for Table/SQL Sources. Best, Jiabao On 2024/01/03 06:51:10 Leonard Xu wrote: > Thanks Jiabao for driving this. > > +1 to start a vote, a minor

Re: [DISCUSS] FLIP-377: Support configuration to disable filter push down for Table/SQL Sources

Thanks Jiabao for driving this. +1 to start a vote, a minor comment, should we change the FLIP title according this thread context as well? Best, Leonard > 2024年1月3日 下午2:43，Jiabao Sun 写道： > > Hi, > > Thank you again for the discussion on this FLIP. > If there are no further comments, I

RE: Re: [DISCUSS] FLIP-377: Support configuration to disable filter push down for Table/SQL Sources

Hi, Thank you again for the discussion on this FLIP. If there are no further comments, I plan to start a voting thread tomorrow. Best, Jiabao On 2023/12/20 14:09:49 Jiabao Sun wrote: > Hi, > > Thank you to everyone for the discussion on this FLIP, > especially Becket for providing guidance

[jira] [Created] (FLINK-33970) Add necessary checks for connector document

Leonard Xu created FLINK-33970: -- Summary: Add necessary checks for connector document Key: FLINK-33970 URL: https://issues.apache.org/jira/browse/FLINK-33970 Project: Flink Issue Type:

Re: [ANNOUNCE] New Apache Flink Committer - Alexander Fedulov

Congratulations Alex

Re: [ANNOUNCE] New Apache Flink Committer - Alexander Fedulov

Congratulations to Alex~ Lijie Wang 于2024年1月3日周三 14:05写道： > Congratulations Alex ! > > Best, > Lijie > > Romit Mahanta 于2024年1月3日周三 13:41写道： > > > Happy New Year & congratulations Alex! > > > > Best, > > > > R > > > > On Tue, 2 Jan, 2024, 5:45 pm Maximilian Michels, wrote: > > > > > Happy New

Re: [ANNOUNCE] New Apache Flink Committer - Alexander Fedulov

Congratulations, Alex! Best, Yuxin Lijie Wang 于2024年1月3日周三 14:04写道： > Congratulations Alex ! > > Best, > Lijie > > Romit Mahanta 于2024年1月3日周三 13:41写道： > > > Happy New Year & congratulations Alex! > > > > Best, > > > > R > > > > On Tue, 2 Jan, 2024, 5:45 pm Maximilian Michels, wrote: > > > >

[DISCUSS] FLIP 411: Chaining-agnostic Operator ID generation for improved state compatibility on parallelism change

Dear Flink devs, I'd like to start a discussion on FLIP 411: Chaining-agnostic Operator ID generation for improved state compatibility on parallelism change [1]. Currently, when user does not explicitly set operator UIDs, the chaining behavior will still affect state compatibility, as the

Re: [ANNOUNCE] New Apache Flink Committer - Alexander Fedulov

Congratulations Alex ! Best, Lijie Romit Mahanta 于2024年1月3日周三 13:41写道： > Happy New Year & congratulations Alex! > > Best, > > R > > On Tue, 2 Jan, 2024, 5:45 pm Maximilian Michels, wrote: > > > Happy New Year everyone, > > > > I'd like to start the year off by announcing Alexander Fedulov as

Re: [ANNOUNCE] New Apache Flink Committer - Alexander Fedulov

Happy New Year & congratulations Alex! Best, R On Tue, 2 Jan, 2024, 5:45 pm Maximilian Michels, wrote: > Happy New Year everyone, > > I'd like to start the year off by announcing Alexander Fedulov as a > new Flink committer. > > Alex has been active in the Flink community since 2019. He has >

Re: [ANNOUNCE] New Apache Flink Committer - Alexander Fedulov

Congratulations! Best, Jingsong On Wed, Jan 3, 2024 at 10:28 AM Benchao Li wrote: > > Congratulations, Alex! > > Yuepeng Pan 于2024年1月3日周三 10:10写道： > > > > Congrats, Alex! > > > > Best, > > Yuepeng Pan > > At 2024-01-02 20:15:08, "Maximilian Michels" wrote: > > >Happy New Year everyone, > > >

[jira] [Created] (FLINK-33969) Implement restore tests for TableSourceScan node

Bonnie Varghese created FLINK-33969: --- Summary: Implement restore tests for TableSourceScan node Key: FLINK-33969 URL: https://issues.apache.org/jira/browse/FLINK-33969 Project: Flink Issue

Re: [2.0] Help needed for release 2.0 work items

> > I would like to ask if there is any plan to review and refactor the CLI in > Flink 2.0. > Not that I'm aware of. I have the impression of seeing discussions about not using CLI options and using only "-Dconfig.key", but I cannot find it now. I personally think that is a good direction to

Re: [2.0] Help needed for release 2.0 work items

Hi Xintong, Thanks for driving this. I would like to ask if there is any plan to review and refactor the CLI in Flink 2.0. I recently found that the CLI commands and parameters are confusing in some ways (e.g. https://github.com/apache/flink/pull/23253#discussion_r1405707256). It would be

Re: [DISCUSS] FLIP-406: Reorganize State & Checkpointing & Recovery Configuration

Thanks for the feedback! Using the `execution.checkpointing.incremental.enabled`, and enabling it by default sounds good to me. Best, Rui On Wed, Jan 3, 2024 at 11:10 AM Zakelly Lan wrote: > Hi Rui, > > Thanks for your comments! > > IMO, given that the state backend can be plugably loaded (as

Re: [DISCUSS] FLIP-406: Reorganize State & Checkpointing & Recovery Configuration

Hi Rui, Thanks for your comments! IMO, given that the state backend can be plugably loaded (as you can specify a state backend factory), I prefer not providing state backend specified options in the framework. Secondly, the incremental checkpoint is actually a sharing file strategy across

[jira] [Created] (FLINK-33968) Compute the number of subpartitions when initializing executon job vertices

Lijie Wang created FLINK-33968: -- Summary: Compute the number of subpartitions when initializing executon job vertices Key: FLINK-33968 URL: https://issues.apache.org/jira/browse/FLINK-33968 Project:

Re: [2.0] Help needed for release 2.0 work items

Thanks a lot for offering the help, Rui. The plan sounds good to me. I'll put your name and the milestones into the 2.0 wiki page. Best, Xintong On Wed, Jan 3, 2024 at 10:38 AM Rui Fan <1996fan...@gmail.com> wrote: > Thanks Xintong for promoting the progress of Flink 2.0. > > If no one

Re: [2.0] Help needed for release 2.0 work items

By the way, some of the refactors of stage2 need to be done in Flink 1.19. Because some Public or PublicEvolving classes are using Time class. Such as: org.apache.flink.api.common.state.StateTtlConfig#newBuilder is using the org.apache.flink.api.common.time.Time. And StateTtlConfig is

Re: [2.0] Help needed for release 2.0 work items

Thanks Xintong for promoting the progress of Flink 2.0. If no one minds, I'd like to pick this one: Use Java’s Duration instead of Flink’s Time. Could I assign FLINK-14068[1] to me? My expected progress is: - Mark org.apache.flink.api.common.time.Time and

Re: [ANNOUNCE] New Apache Flink Committer - Alexander Fedulov

Congratulations, Alex! Yuepeng Pan 于2024年1月3日周三 10:10写道： > > Congrats, Alex! > > Best, > Yuepeng Pan > At 2024-01-02 20:15:08, "Maximilian Michels" wrote: > >Happy New Year everyone, > > > >I'd like to start the year off by announcing Alexander Fedulov as a > >new Flink committer. > > > >Alex

Re:[ANNOUNCE] New Apache Flink Committer - Alexander Fedulov

Congrats, Alex! Best, Yuepeng Pan At 2024-01-02 20:15:08, "Maximilian Michels" wrote: >Happy New Year everyone, > >I'd like to start the year off by announcing Alexander Fedulov as a >new Flink committer. > >Alex has been active in the Flink community since 2019. He has >contributed more than

Re: [ANNOUNCE] New Apache Flink Committer - Alexander Fedulov

Congratulations~! Best, Xintong On Wed, Jan 3, 2024 at 9:36 AM Leonard Xu wrote: > Congrats, Alex! > > Best, > Leonard > > > 2024年1月3日 上午4:11，Tang, Zhiyan (udx2na) 写道： > > > > big congrats to Alex and Happy New Year everyone! > > > > Best > > Tony > > > > Get Outlook for

Re: [ANNOUNCE] New Apache Flink Committer - Alexander Fedulov

Congrats, Alex! Best, Leonard > 2024年1月3日 上午4:11，Tang, Zhiyan (udx2na) 写道： > > big congrats to Alex and Happy New Year everyone! > > Best > Tony > > Get Outlook for iOS > > From: Austin Cawley-Edwards > Sent: Tuesday, January 2, 2024

[2.0] Help needed for release 2.0 work items

Hi devs, The release managers have been tracking the progress of release 2.0 work items. Unfortunately, some of the items are not in good progress, and either don't have a contributor or the original contributor no longer has capacity to work on them. We have already tried reaching out to some

[jira] [Created] (FLINK-33967) Remove/Rename log4j2-test.properties in flink-streaming-java's test bundle

Koala Lam created FLINK-33967: - Summary: Remove/Rename log4j2-test.properties in flink-streaming-java's test bundle Key: FLINK-33967 URL: https://issues.apache.org/jira/browse/FLINK-33967 Project: Flink

Re: [Discuss][Flink-31326] Flink autoscaler code

Hello Rui, Here is the jira ticket https://issues.apache.org/jira/browse/FLINK-33966, I have pushed a tiny pr for this ticket. Regards, Yang On Tue, 2 Jan 2024 at 16:15, Rui Fan <1996fan...@gmail.com> wrote: > Thanks Yang for

[jira] [Created] (FLINK-33966) Fix the getNumRecordsInPerSecond Utility Function

Yang LI created FLINK-33966: --- Summary: Fix the getNumRecordsInPerSecond Utility Function Key: FLINK-33966 URL: https://issues.apache.org/jira/browse/FLINK-33966 Project: Flink Issue Type: Bug

Re: [ANNOUNCE] New Apache Flink Committer - Alexander Fedulov

big congrats to Alex and Happy New Year everyone! Best Tony Get Outlook for iOS From: Austin Cawley-Edwards Sent: Tuesday, January 2, 2024 2:07:49 PM To: dev@flink.apache.org Cc: Alexander Fedulov Subject: Re: [ANNOUNCE] New Apache Flink

Re: [ANNOUNCE] New Apache Flink Committer - Alexander Fedulov

Congrats Alex!! On Tue, Jan 2, 2024 at 10:12 Feng Jin wrote: > Congratulations, Alex! > > Best, > Feng > > On Tue, Jan 2, 2024 at 11:04 PM Chen Yu wrote: > > > Congratulations, Alex! > > > > Best, > > Yu Chen > > > > > > 发件人: Zhanghao Chen > > 发送时间:

Re: [VOTE] FLIP-372: Allow TwoPhaseCommittingSink WithPreCommitTopology to alter the type of the Committable

+1 (binding) looks good to me overall thank you for revising the FLIP and continuing to drive the decision, Peter! On Wed, Dec 27, 2023 at 7:16 AM Martijn Visser wrote: > Hi Peter, > > It would be good if Gordon can take a look, but overall this looks good to > me +1 > > Best regards, > >

Re: [VOTE] FLIP-400: AsyncScalarFunction for asynchronous scalar function support

+1 (binding) Best, Piotrek czw., 28 gru 2023 o 09:19 Timo Walther napisał(a): > +1 (binding) > > Cheers, > Timo > > > Am 28.12.2023 um 03:13 schrieb Yuepeng Pan : > > > > +1 (non-binding). > > > > Best, > > Yuepeng Pan. > > > > > > > > > > At 2023-12-28 09:19:37, "Lincoln Lee" wrote: > >> +1

Re: [Discuss][Flink-31326] Flink autoscaler code

Thanks Yang for reporting this issue! You are right, these 2 conditions are indeed the same. It's unexpected IIUC. Would you like to fix it? Feel free to create a FLINK JIRA to fix it if you would like to, and I'm happy to review! And cc @Maximilian Michels Best, Rui On Tue, Jan 2, 2024 at

Re: [ANNOUNCE] New Apache Flink Committer - Alexander Fedulov

Congratulations, Alex! Best, Feng On Tue, Jan 2, 2024 at 11:04 PM Chen Yu wrote: > Congratulations, Alex! > > Best, > Yu Chen > > > 发件人: Zhanghao Chen > 发送时间: 2024年1月2日 22:44 > 收件人: dev > 抄送: Alexander Fedulov > 主题: Re: [ANNOUNCE] New Apache Flink

回复: [ANNOUNCE] New Apache Flink Committer - Alexander Fedulov

Congratulations, Alex! Best, Yu Chen 发件人: Zhanghao Chen 发送时间: 2024年1月2日 22:44 收件人: dev 抄送: Alexander Fedulov 主题: Re: [ANNOUNCE] New Apache Flink Committer - Alexander Fedulov Congrats, Alex! Best, Zhanghao Chen From:

[Discuss][Flink-31326] Flink autoscaler code

Hello, I see we have 2 times the same condition check in the function getNumRecordsInPerSecond (L220 and L224

Re: [ANNOUNCE] New Apache Flink Committer - Alexander Fedulov

Congrats, Alex! Best, Zhanghao Chen From: Maximilian Michels Sent: Tuesday, January 2, 2024 20:15 To: dev Cc: Alexander Fedulov Subject: [ANNOUNCE] New Apache Flink Committer - Alexander Fedulov Happy New Year everyone, I'd like to start the year off by

Re: [ANNOUNCE] New Apache Flink Committer - Alexander Fedulov

That's great news. Congratulations, Alex! David On Tue, Jan 2, 2024 at 9:00 AM Ryan Skraba wrote: > Awesome news for the community -- congratulations Alex (and Happy New > Year everyone!) > > Ryan > > On Tue, Jan 2, 2024 at 2:55 PM Yun Tang wrote: > > > > Congratulation to Alex and Happy New

Re: [ANNOUNCE] New Apache Flink Committer - Alexander Fedulov

Awesome news for the community -- congratulations Alex (and Happy New Year everyone!) Ryan On Tue, Jan 2, 2024 at 2:55 PM Yun Tang wrote: > > Congratulation to Alex and Happy New Year everyone! > > Best > Yun Tang > > From: Rui Fan <1996fan...@gmail.com> > Sent:

Re: [ANNOUNCE] New Apache Flink Committer - Alexander Fedulov

Congratulation to Alex and Happy New Year everyone! Best Yun Tang From: Rui Fan <1996fan...@gmail.com> Sent: Tuesday, January 2, 2024 21:33 To: dev@flink.apache.org Cc: Alexander Fedulov Subject: Re: [ANNOUNCE] New Apache Flink Committer - Alexander Fedulov

Re: [ANNOUNCE] New Apache Flink Committer - Alexander Fedulov

Happy new year! Hmm, sorry for the typo in the last email. Congratulations Alex, well done! Best, Rui On Tue, 2 Jan 2024 at 20:23, Rui Fan <1996fan...@gmail.com> wrote: > Configurations Alexander! > > Best, > Rui > > On Tue, Jan 2, 2024 at 8:15 PM Maximilian Michels wrote: > >> Happy New Year

Re: [ANNOUNCE] New Apache Flink Committer - Alexander Fedulov

Configurations Alexander! Best, Rui On Tue, Jan 2, 2024 at 8:15 PM Maximilian Michels wrote: > Happy New Year everyone, > > I'd like to start the year off by announcing Alexander Fedulov as a > new Flink committer. > > Alex has been active in the Flink community since 2019. He has >

[ANNOUNCE] New Apache Flink Committer - Alexander Fedulov

Happy New Year everyone, I'd like to start the year off by announcing Alexander Fedulov as a new Flink committer. Alex has been active in the Flink community since 2019. He has contributed more than 100 commits to Flink, its Kubernetes operator, and various connectors [1][2]. Especially

Re: [DISCUSS][FLINK-31830] Align the Nullability Handling of ROW between SQL and TableAPI

Hi Jane, thanks for the heavy investigation and extensive summaries. I'm sorry that I ignored this discussion for too long but would like to help in shaping a sustainable long-term solution. I fear that changing: - RowType#copy() - RowType's constructor - FieldsDataType#nullable() will not

[jira] [Created] (FLINK-33965) Refactor the configuration for autoscaler standalone

Rui Fan created FLINK-33965: --- Summary: Refactor the configuration for autoscaler standalone Key: FLINK-33965 URL: https://issues.apache.org/jira/browse/FLINK-33965 Project: Flink Issue Type:

[jira] [Created] (FLINK-33964) Flink documentation can't be build due to error in Pulsar docs

Martijn Visser created FLINK-33964: -- Summary: Flink documentation can't be build due to error in Pulsar docs Key: FLINK-33964 URL: https://issues.apache.org/jira/browse/FLINK-33964 Project: Flink

Re: [DISCUSS] FLIP-397: Add config options for administrator JVM options

Hi Zhanghao, Thx for reply. LGTM now. Zhanghao Chen 于2024年1月2日周二 10:29写道： > Hi Xiangyu, > > The proposed new options are targeted on experienced Flink platform > administrators instead of normal end users, and a one-by-one mapping from > non-default option to the default option variant might