Re: [ANNOUNCE] New Apache Flink PMC Member - Qingsheng Ren

Congratulations, Qingsheng! Best regards, Weijie Geng Biao 于2023年4月23日周日 14:29写道： > Congrats, Qingsheng! > Best, > Biao Geng > > 获取 Outlook for iOS > > 发件人: Wencong Liu > 发送时间: Sunday, April 23, 2023 11:06:39 AM > 收件人: dev@flink.apache.

Re: [ANNOUNCE] New Apache Flink PMC Member - Leonard Xu

Congratulations, Leonard! Best regards, Weijie Geng Biao 于2023年4月23日周日 14:30写道： > Congrats, Lenorad! > Best, > Biao Geng > > 获取 Outlook for iOS > > 发件人: Wencong Liu > 发送时间: Sunday, April 23, 2023 11:05:41 AM > 收件人: dev@flink.apache.org

Re: [DISCUSS] Preventing Mockito usage for the new code with Checkstyle

+1 for introducing this rule for junit4 and mockito. Best regards, Weijie Alexander Fedulov 于2023年4月26日周三 23:50写道： > +1 for the proposal, > > Best, > Alex > > On Wed, 26 Apr 2023 at 15:50, Chesnay Schepler wrote: > > > * adds a note to not include "import " in the regex" * > > > > On 26/04/2

[DISCUSS] Release Flink 1.16.2

Hi all, I would like to discuss creating a new 1.16 patch release (1.16.2). The last 1.16 release is over three months old, and since then, 99 tickets have been closed [1], of which 30 are blocker/critical [2]. Some of them are quite important, such as FLINK-31293 [3] and FLINK-32027 [4]. I am

Re: [DISCUSS] Release Flink 1.16.2

/versions/12352765 weijie guo 于2023年5月11日周四 11:06写道： > Hi all, > > > I would like to discuss creating a new 1.16 patch release (1.16.2). The > last 1.16 release is over three months old, and since then, 99 tickets have > been closed [1], of which 30 are blocker/critical [2].

[DISCUSS] Release Flink 1.17.1

Hi all, I would like to discuss creating a new 1.17 patch release (1.17.1). The last 1.17 release is nearly two months old, and since then, 66 tickets have been closed [1], of which 14 are blocker/critical [2]. Some of them are quite important, such as FLINK-31293 [3] and FLINK-32027 [4]. I a

Re: [DISCUSS] Release Flink 1.17.1

.17.1 > > > > > > > > > > > > Best, > > > > > > Jingsong > > > > > > > > > > > > On Thu, May 11, 2023 at 1:29 PM Gyula Fóra > > > > > wrote: > > > > > > > > > >

Re: [DISCUSS] Release Flink 1.16.2

at 3:13 PM Jingsong Li > > wrote: > > > > > +1 for releasing 1.16.2 > > > > > > Best, > > > Jingsong > > > > > > On Thu, May 11, 2023 at 1:28 PM Gyula Fóra > wrote: > > > > > > > > +1 for the release >

[VOTE] Release 1.16.2, release candidate #1

Hi everyone, Please review and vote on the release candidate #1 for the version 1.16.2, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) The complete staging area is available for your review, which includes: * JIRA release notes

Re: [DISCUSS] Release Flink 1.17.1

no later than next Monday at the latest. Best regards, Weijie Jing Ge 于2023年5月19日周五 14:48写道： > Hi Weijie, > > just wondering how the process is going. Will the RC1 be released today? > Thanks for driving this! > > Best regards, > Jing > > On Wed, May 17, 2023 at

[VOTE] Release 1.17.1, release candidate #1

Hi everyone, Please review and vote on the release candidate #1 for the version 1.17.1, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) The complete staging area is available for your review, which includes: * JIRA release notes

[RESULT][VOTE] Release 1.16.2, release candidate #1

I'm happy to announce that we have unanimously approved this release. There are 8 approving votes, 3 of which are binding: * Yuxin Tan * Yun Tang * Jing Ge * Xintong Song(binding) * Xingbo Huang(binding) * Qingsheng Ren(binding) * Samrat Deb * Hang Ruan There are no disapproving votes

Re: [VOTE] Release 1.16.2, release candidate #1

2023 at 11:51 AM Yun Tang > > wrote: > > > > > > > > > > > > > +1 (non-binding) > > > > > > > > > > > > > > > > > > > > > * Verified signatures > > > > > > >

[RESULT] [VOTE] Release 1.17.1, release candidate #1

I'm happy to announce that we have unanimously approved this release. There are 7 approving votes, 3 of which are binding: * Xintong Song(binding) * Yuxin Tan * Xingbo Huang(binding) * Yun Tang * Jing Ge * Qingsheng Ren(binding) * Benchao Li There are no disapproving votes. I'll work

Re: [RESULT] [VOTE] Release 1.17.1, release candidate #1

Jing > > On Thu, May 25, 2023 at 9:46 AM weijie guo > wrote: > > > I'm happy to announce that we have unanimously approved this release. > > > > > > > > There are 7 approving votes, 3 of which are binding: > > > > > > * Xin

[ANNOUNCE] Apache Flink 1.16.2 released

The Apache Flink community is very happy to announce the release of Apache Flink 1.16.2, which is the second bugfix release for the Apache Flink 1.16 series. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data streamin

[ANNOUNCE] Apache Flink 1.17.1 released

The Apache Flink community is very happy to announce the release of Apache Flink 1.17.1, which is the first bugfix release for the Apache Flink 1.17 series. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data streaming

Re: [ANNOUNCE] Apache Flink 1.16.2 released

gt; On Fri, May 26, 2023 at 4:41 PM Martijn Visser > wrote: > > > Thank you Weijie and those who helped with testing! > > > > On Fri, May 26, 2023 at 1:06 PM weijie guo > > wrote: > > > > > The Apache Flink community is very happy to announce the release

Re: [VOTE] Release flink-connector-jdbc v3.1.1, release candidate #1

+1 (non-binding) - checked sign and checksum - checked tag in github repository - compiled from source - checked the web PR BTW, please remember to update docs/jdbc.yaml for the v3.1 branch after the release is completed. Best regards, Weijie Jing Ge 于2023年5月29日周一 04:26写道： > +1 (non-binding

Re: [VOTE] FLIP-315: Support Operator Fusion Codegen for Flink SQL

+1 (binding) Best regards, Weijie Jingsong Li 于2023年6月7日周三 15:59写道： > +1 > > On Wed, Jun 7, 2023 at 3:03 PM Benchao Li wrote: > > > > +1, binding > > > > Jark Wu 于2023年6月7日周三 14:44写道： > > > > > +1 (binding) > > > > > > Best, > > > Jark > > > > > > > 2023年6月7日 14:20，liu ron 写道： > > > > > >

Re: [DISCUSS][2.0] FLIP-343: Remove parameter in WindowAssigner#getDefaultTrigger()

+1 for this. Best regards, Weijie liu ron 于2023年7月24日周一 09:58写道： > +1 > > Best, > Ron > > Yuxin Tan 于2023年7月21日周五 16:21写道： > > > +1 > > > > Best, > > Yuxin > > > > > > Jing Ge 于2023年7月21日周五 15:41写道： > > > > > +1 > > > > > > NIT: the release in the FLIP is still empty, it should be 2.0 > > >

Re: Re: [DISCUSS][2.0] FLIP-347: Remove IOReadableWritable serialization in Path

+1 Best regards, Weijie Jing Ge 于2023年7月22日周六 00:47写道： > Hi Wencong, > > Thanks for the clarification. I got your point. It makes sense. > > Wrt IOReadableWritable, the suggestion was to check all classes that > implemented it, e.g. BlockInfo, Value, Configuration, etc. Not limited to > the P

Re: Re: [ANNOUNCE] New Apache Flink Committer - Yong Fang

Congrats, Yong Fang! Best regards, Weijie Danny Cranmer 于2023年7月26日周三 03:34写道： > Congrats and welcome! > > Danny. > > On Tue, 25 Jul 2023, 16:48 Matthias Pohl, > wrote: > > > Congratulations :) > > > > On Tue, Jul 25, 2023 at 5:13 PM Jing Ge > > wrote: > > > > > Congrats, Yong Fang! > > > >

Re: [VOTE][2.0] FLIP-343: Remove parameter in WindowAssigner#getDefaultTrigger()

+1 (binding) Best regards, Weijie Wencong Liu 于2023年7月26日周三 14:26写道： > Hi dev, > > > I'd like to start a vote on FLIP-343. > > > Discussion thread: > https://lists.apache.org/thread/zn11f460x70nn7f2ckqph41bvx416wxc > FLIP: > https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=263

Re: [VOTE][2.0] FLIP-347: Remove IOReadableWritable serialization in Path

+1 (binding) Best regards, Weijie Yuxin Tan 于2023年7月26日周三 16:11写道： > +1 (non-binding) > > Best, > Yuxin > > > Xintong Song 于2023年7月26日周三 16:09写道： > > > +1 (binding) > > > > Best, > > > > Xintong > > > > > > > > On Wed, Jul 26, 2023 at 2:29 PM Wencong Liu > wrote: > > > > > Hi dev, > > > > >

Re: [VOTE][2.0] FLIP-344: Remove parameter in RichFunction#open

+1 (binding) Best regards, Weijie Yuxin Tan 于2023年7月26日周三 16:11写道： > +1 (non-binding) > > Best, > Yuxin > > > Xintong Song 于2023年7月26日周三 16:09写道： > > > +1 (binding) > > > > Best, > > > > Xintong > > > > > > > > On Wed, Jul 26, 2023 at 2:26 PM Wencong Liu > wrote: > > > > > Hi dev, > > > > >

Re: [ANNOUNCE] New Apache Flink Committer - Weihua Hu

Congratulations Weihua! Best regards, Weijie Lijie Wang 于2023年8月4日周五 15:28写道： > Congratulations, Weihua! > > Best, > Lijie > > yuxia 于2023年8月4日周五 15:14写道： > > > Congratulations, Weihua! > > > > Best regards, > > Yuxia > > > > - 原始邮件 - > > 发件人: "Yun Tang" > > 收件人: "dev" > > 发送时间: 星期

Re: [ANNOUNCE] New Apache Flink PMC Member - Matthias Pohl

Congratulations, Matthias! Best regards, Weijie Wencong Liu 于2023年8月4日周五 15:50写道： > Congratulations, Matthias! > > Best, > Wencong Liu > > > > > > > > > > > > > > > > > > At 2023-08-04 11:18:00, "Xintong Song" wrote: > >Hi everyone, > > > >On behalf of the PMC, I'm very happy to announce tha

Re: [ANNOUNCE] New Apache Flink Committer - Hong Teoh

Congratulations, Hong! Best regards, Weijie Lijie Wang 于2023年8月4日周五 15:31写道： > Congratulations, Hong! > > Best, > Lijie > > Paul Lam 于2023年8月4日周五 15:18写道： > > > Congrats, Hong! > > > > Best, > > Paul Lam > > > > > 2023年8月4日 14:59，Jark Wu 写道： > > > > > > Congratulations, Hong! > > > > > > Be

Re: [ANNOUNCE] New Apache Flink Committer - Hangxiang Yu

Congrats, Hangxiang! Best regards, Weijie Biao Geng 于2023年8月7日周一 17:04写道： > Congrats, Hangxiang! > Best, > Biao Geng > > > 发送自 Outlook for iOS > > 发件人: Qingsheng Ren > 发送时间: Monday, August 7, 2023 4:23:11 PM > 收件人: dev@flink.apache.org

Re: [ANNOUNCE] New Apache Flink Committer - Yanfei Lei

Congrats, Yanfei! Best regards, Weijie Biao Geng 于2023年8月7日周一 17:03写道： > Congrats, Yanfei! > Best, > Biao Geng > > 发送自 Outlook for iOS > > 发件人: Qingsheng Ren > 发送时间: Monday, August 7, 2023 4:23:52 PM > 收件人: dev@flink.apache.org > 主题: R

Re: [DISCUSS] FLIP-357: Deprecate Iteration API of DataStream

Thanks, +1 for this. Best regards, Weijie Yangze Guo 于2023年9月1日周五 14:29写道： > +1 > > Thanks for driving this. > > Best, > Yangze Guo > > On Fri, Sep 1, 2023 at 2:00 PM Xintong Song wrote: > > > > +1 > > > > Best, > > > > Xintong > > > > > > > > On Fri, Sep 1, 2023 at 1:11 PM Dong Lin wrote:

Re: [VOTE] FLIP-366: Support standard YAML for FLINK configuration

+1(binding) Best regards, Weijie Samrat Deb 于2023年10月13日周五 10:21写道： > +1 (non binding ) > > On Fri, 13 Oct 2023 at 7:47 AM, Rui Fan <1996fan...@gmail.com> wrote: > > > +1(binding) > > > > Best, > > Rui Fan > > > > On Fri, Oct 13, 2023 at 10:12 AM Junrui Lee wrote: > > > > > Hi all, > > > > >

Re: [DISCUSS] FLIP-381: Deprecate configuration getters/setters that return/set complex Java objects

Thanks Junrui for driving this proposal! I believe this is helpful for the new Process Function API. Because we don't need to move some related class/components from flink-core to a pure API module (maybe, called flink-core-api) after this. Even though the FLIP related to new API is in preparation

Re: [DISCUSS] Release flink-shaded 16.2

Thanks Yuxin for driving this! I am willing to help release this. :) Best regards, Weijie Yuxin Tan 于2023年11月6日周一 15:45写道： > Hi, all, > > I would like to discuss creating a new 16.2 patch release for > flink-shaded[1]. > > In our ARM environment, we recently encountered a critical bug > (FLI

Re: [VOTE] FLIP-381: Deprecate configuration getters/setters that return/set complex Java objects

+1(binding) Best regards, Weijie Lijie Wang 于2023年11月13日周一 10:40写道： > +1 (binding) > > Best, > Lijie > > Yuepeng Pan 于2023年11月10日周五 18:32写道： > > > +1(non-binding) > > > > Best, > > Roc > > > > On 2023/11/10 03:58:10 Junrui Lee wrote: > > > Hi everyone, > > > > > > Thank you to everyone for t

[VOTE] Release flink-shaded 16.2, release candidate #1

Hi everyone, Please review and vote on the release candidate #1 for the version 16.2, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) The complete staging area is available for your review, which includes: * JIRA release notes [

[RESULT] [VOTE] flink-shaded 16.2, release candidate #1

I'm happy to announce that we have unanimously approved this release. There are 4 approving votes, 3 of which are binding: * Yuxin Tan(non-binding) * Xintong Song(binding) * Zhu Zhu(binding) * Martijn Visser(binding) There are no disapproving votes. Thanks everyone!

[ANNOUNCE] Apache Flink-shaded 16.2 released

The Apache Flink community is very happy to announce the release of Apache Flink-shaded 16.2. The flink-shaded project contains a number of shaded dependencies for Apache Flink. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and

Re: [VOTE] Release 1.17.2, release candidate #1

+1 (binding) - Verified signatures and hashsums - Verified POM/NOTICE filess - Built from sources. - Reviewed the web PR. Best regards, Weijie Yuxin Tan 于2023年11月24日周五 10:18写道： > +1 (non-binding) > > - Verified signatures and hashsums > - Verified there are no binaries in the source archive

Re: [VOTE] Release 1.17.2, release candidate #1

Sorry, it's a non-binding vote. :) Best regards, Weijie weijie guo 于2023年11月24日周五 11:05写道： > +1 (binding) > > - Verified signatures and hashsums > - Verified POM/NOTICE filess > - Built from sources. > - Reviewed the web PR. > > Best regards, > > Weijie >

Re: [VOTE] FLIP-391: Deprecate RuntimeContext#getExecutionConfig

Thanks Junrui for driving this! +1(binding) Best regards, Weijie Zhanghao Chen 于2023年11月28日周二 17:29写道： > +1 (non-binding) > > Best, > Zhanghao Chen > > From: Junrui Lee > Sent: Tuesday, November 28, 2023 12:34 > To: dev@flink.apache.org > Subject: [VOTE] FL

Re: [DISCUSS] FLIP-335: Removing Flink's Time classes as part of Flink 2.0

Thanks for driving this FLIP, Matthias. I'm +1 for this. Best regards, Weijie Matthias Pohl 于2023年7月19日周三 22:32写道： > The overall Scala-related plan for this FLIP is to ignore the Scala API > because of FLIP-265. The CEP Java/Scala version > parity (through the PatternScalaAPICompletenessTest

Re: [DISCUSS] Resolve diamond inheritance of Sink.createWriter

Thanks Martijn for driving this! I'm +1 to reverting the breaking change. > For new functionality or changes we can make easily, we should switch to the decorative/mixin interface approach used successfully in the source and table interfaces. I like the way of switching to mixin interface. Bes

Re: [VOTE] FLIP-396: Trial to test GitHub Actions as an alternative for Flink's current Azure CI infrastructure

Thanks Matthias for this efforts. +1(binding) Best regards, Weijie Matthias Pohl 于2023年12月11日周一 21:51写道： > Hi everyone, > I'd like to start a vote on FLIP-396 [1]. It covers enabling GitHub Actions > (GHA) in Apache Flink. This means that GHA workflows will run aside from > the usual Azure

Re: [DISCUSS] FLIP-398: Improve Serialization Configuration And Usage In Flink

Thanks for driving this, Yong. This FLIP look good to me overall. I also used a similar approach to decouple the serializer from ExecutionConfig in the PoC of DataStream API V2. I'm +1 for this. Best regards, Weijie Xintong Song 于2023年12月12日周二 12:10写道： > Thanks for working on this, Yong. >

Re: [DISCUSS] Release Flink 1.18.1

Thanks Jing for driving this bug-fix release. +1 from my side. Best regards, Weijie Jark Wu 于2023年12月12日周二 12:17写道： > Thanks Jing for driving 1.18.1. > +1 for this. > > Best, > Jark > > On Mon, 11 Dec 2023 at 16:59, Hong Liang wrote: > > > +1. Thanks Jing for driving this. > > > > Hong > >

Re: [DISCUSS] FLIP-380: Support Full Partition Processing On Non-keyed DataStream

Thanks Wencong for driving this! I believe this is a useful feature, so +1 from my side. I only have one minor question about the exchange mode of `xxxPartition` method. Does this means the window operator must be connected to the upstream operator in forward edge (otherwise the concept of mapPar

Re: [DISCUSS][2.0] FLIP-382: Unify the Provision of Diverse Metadata for Context-like APIs

Hi Wencong, Thanks for driving this! This is valuable refactoring from my side, so I'm +1 for this proposal. Best regards, Weijie Lijie Wang 于2023年12月12日周二 14:58写道： > Hi Wencong > > Thanks for driving the discussion, +1 for the proposal. I left two minor > questions/suggestions: > > 1. Is t

Re: Re: [DISCUSS] FLIP-380: Support Full Partition Processing On Non-keyed DataStream

glad to assist > if you have any more questions or insights to share. > > Best regards, > > Wencong > [1] > https://cwiki.apache.org/confluence/display/FLINK/FLIP-380%3A+Support+Full+Partition+Processing+On+Non-keyed+DataStream > > > > > > > > > >

Re: [VOTE] FLIP-382: Unify the Provision of Diverse Metadata for Context-like APIs

+1(binding) Best regards, Weijie Wencong Liu 于2023年12月15日周五 09:13写道： > Hi dev, > > I'd like to start a vote on FLIP-382. > > Discussion thread: > https://lists.apache.org/thread/3mgsc31odtpmzzl32s4oqbhlhxd0mn6b > FLIP: > https://cwiki.apache.org/confluence/display/FLINK/FLIP-382%3A+Unify+the+

Re: [VOTE] FLIP-383: Support Job Recovery for Batch Jobs

+1 (binding) Best regards, Weijie Zhu Zhu 于2023年12月15日周五 10:49写道： > +1 (binding) > > Thanks, > Zhu > > Xintong Song 于2023年12月14日周四 15:36写道： > > > +1 (binding) > > > > Best, > > > > Xintong > > > > > > > > On Thu, Dec 14, 2023 at 3:15 PM Lijie Wang > > wrote: > > > > > Hi devs, Thanks for al

Re: [VOTE] FLIP-380: Support Full Partition Processing On Non-keyed DataStream

+1 (binding) Best regards, Weijie Wencong Liu 于2023年12月15日周五 09:15写道： > Hi dev, > > I'd like to start a vote on FLIP-380. > > Discussion thread: > https://lists.apache.org/thread/nn7myj7vsvytbkdrnbvj5h0homsjrn1h > FLIP: > https://cwiki.apache.org/confluence/display/FLINK/FLIP-380%3A+Support+F

Re: [VOTE] FLIP-364: Update the default value of backoff-multiplier from 1.2 to 1.5

+1(binding) Best regards, Weijie Xin Jiang 于2023年12月21日周四 11:21写道： > 1.5 multiplier is indeed more reasonable. > > +1 (non-binding) > > > 2023年12月19日 下午5:17，Rui Fan <1996fan...@gmail.com> 写道： > > > > Hi everyone, > > > > Thank you to everyone for the feedback on FLIP-364: > > Improve the rest

[DISCUSS] FLIP-408: [Umbrella] Introduce DataStream API V2

Hi devs, I'd like to start a discussion about FLIP-408: [Umbrella] Introduce DataStream API V2 [1]. The DataStream API is one of the two main APIs that Flink provides for writing data processing programs. As an API that was introduced practically since day-1 of the project and has been evolved

[DISCUSS] FLIP-409: DataStream V2 Building Blocks: DataStream, Partitioning and ProcessFunction

Hi devs, I'd like to start a discussion about FLIP-409: DataStream V2 Building Blocks: DataStream, Partitioning and ProcessFunction [1]. As the first sub-FLIP for DataStream API V2, we'd like to discuss and try to answer some of the most fundamental questions in stream processing: 1. What k

[DISCUSS] FLIP-410: Config, Context and Processing Timer Service of DataStream API V2

Hi devs, I'd like to start a discussion about FLIP-410: Config, Context and Processing Timer Service of DataStream API V2 [1]. This is the second sub-FLIP of DataStream API V2. In FLIP-409 [2], we have defined the most basic primitive of DataStream V2. On this basis, this FLIP will further answ

Re: [VOTE] FLIP-398: Improve Serialization Configuration And Usage In Flink

+1(binding) Best regards, Weijie Zhu Zhu 于2023年12月27日周三 18:54写道： > +1 (binding) > > Thanks, > Zhu > > Zhanghao Chen 于2023年12月27日周三 15:41写道： > > > +1 (non-binding) > > > > Best, > > Zhanghao Chen > > > > From: Yong Fang > > Sent: Wednesday, December 27, 2023

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

Congratulations, Alex! Best regards, Weijie Steven Wu 于2024年1月4日周四 02:07写道： > Congra, Alex! Well deserved! > > On Wed, Jan 3, 2024 at 2:31 AM David Radley > wrote: > > > Sorry for my typo. > > > > Many congratulations Alex! > > > > From: David Radley > > Date: Wednesday, 3 January 2024 at 1

Re: [DISCUSS]Introduce a time-segment based restart strategy

Hi, all, Thank you very much for this interesting discussion. TBH, Dong's proposal made me very excited. Our users don't need to be tortured by choosing the right one among many strategies. However, as Gen said, it may need to make some changes to the RestartBackoffTimeStrategy interface as it d

Re: [DISCUSS] Cleaning up HighAvailabilityServices interface to reflect the per-JM-process LeaderElection

Hi Matthias, Thanks for the proposal! I am in favor of cleaning up this interface, and It seems a bit cumbersome now. Especially, the implementation of per-component leader election has been removed from our current code path. To be honest, I don't like the per-component approach. I'm even often

[DISCUSS] Check and add sql-connector uber jar e2e tests

Hi devs, I'd like to start a discussion about adding sql-connector's uber jar e2e test for connectors. I know that some connectors like kafka and HBase have corresponding sql connector uber jar's test, which are located in SqlClientITCase and SQLClientHBaseITCase respectively. However, some sql

Re: [DISCUSS] Check and add sql-connector uber jar e2e tests

> Speaking from AWS connectors side, we have maintained e2e tests for > > Kinesis and Firehose sql connectors, DDB to follow. > > Happy to coordinate regarding any new conventions or suggestions. > > > > On 09/01/2023, 05:48, "weijie guo" wrote: > > >

Re: [DISCUSS] Check and add sql-connector uber jar e2e tests

Hi All, Thank you for all your comments. If there is no further concern, I will create the umbrella JIRA and promote the smoke test of connectors. Best regards, Weijie weijie guo 于2023年1月9日周一 18:06写道： > Hi Hamdy and Martijn, > > Thanks for quickly reply. > > SmokeKafk

Re: [ANNOUNCE] New Apache Flink Committer - Lincoln Lee

Congratulations, Lincoln! Best regards, Weijie Lijie Wang 于2023年1月10日周二 12:24写道： > Congratulations, Lincoln! > > Best, > Lijie > > Jingsong Li 于2023年1月10日周二 12:07写道： > > > Congratulations, Lincoln! > > > > Best, > > Jingsong > > > > On Tue, Jan 10, 2023 at 11:56 AM Leonard Xu wrote: > > > >

Re: [VOTE] FLIP-283: Use adaptive batch scheduler as default scheduler for batch jobs

+1 (non-binding) Best regards, Weijie yuxia 于2023年1月10日周二 18:06写道： > +1 (non-binding) > > Best regards, > Yuxia > > - 原始邮件 - > 发件人: "Zhu Zhu" > 收件人: "dev" > 发送时间: 星期二, 2023年 1 月 10日 下午 5:49:58 > 主题: Re: [VOTE] FLIP-283: Use adaptive batch scheduler as default scheduler > for batch j

Re: [VOTE] FLIP-285: Refactoring LeaderElection to make Flink support multi-component leader election out-of-the-box

+1 non-binding Best regards, Weijie Rui Fan <1996fan...@gmail.com> 于2023年1月30日周一 18:57写道： > +1 non-binding > > Best > > Rui Fan > > On Thu, Jan 26, 2023 at 19:07 Chesnay Schepler wrote: > > > +1 > > > > On 25/01/2023 10:33, Matthias Pohl wrote: > > > Hi everyone, > > > After the discussion th

Re: unsucscribe

Hi Jake, Please email dev-unsubscr...@flink.apache.org as describe here: https://flink.apache.org/community.html Best regards, Weijie Jake 于2023年1月29日周日 10:48写道： >

Re: [VOTE] FLIP-290: Operator state compression (FLINK-30113)

+1 (binding) Thanks for driving this Best regards, Weijie Yuan Mei 于2023年1月28日周六 13:37写道： > +1 binding > > Best > Yuan > > On Sat, Jan 21, 2023 at 12:49 AM Rui Fan <1996fan...@gmail.com> wrote: > > > +1 (no-binding) > > > > Best > > Rui Fan > > > > On Fri, Jan 20, 2023 at 10:46 PM ConradJam

Re: [VOTE] FLIP-279 Unified the max display column width for SqlClient and Table APi in both Streaming and Batch execMode

+1 (no-binding) Best regards, Weijie godfrey he 于2023年1月16日周一 18:11写道： > +1 (binding) > > Best, > Godfrey > > Shammon FY 于2023年1月12日周四 23:27写道： > > > > +1 (no-binding) > > > > > > Best, > > Shammon > > > > On Thu, Jan 12, 2023 at 8:11 PM Shengkai Fang wrote: > > > > > +1(binding) > > > > >

Re: [ANNOUNCE] Apache Flink 1.16.1 released

Thank Martin for managing the release and all the people involved. Best regards, Weijie Konstantin Knauf 于2023年2月2日周四 06:40写道： > Great. Thanks, Martijn for managing the release. > > Am Mi., 1. Feb. 2023 um 20:26 Uhr schrieb Martijn Visser < > martijnvis...@apache.org>: > > > The Apache Flink

Re: Reworking the Rescale API

Hi David, Sorry I'm late to join discuss. +1 for having a more structure doc about scheduler ecosystem and I can help to fill in the details about batch part. Best regards, Weijie David Morávek 于2023年2月1日周三 22:38写道： > It makes sense to give the whole "scheduler ecosystem," not just the > ad

Re: [DISCUSS] FLIP-291: Externalized Declarative Resource Management

Thanks David for driving this. This is a very valuable work, especially for cloud native environment. >> How about adding some more information such as vertex type (SOURCE/MAP/JOIN and .etc) in the response of `get jobs resource-requirements`? For users, only vertex-id may be difficult to understa

Re: [VOTE] FLIP-274: Introduce metric group for OperatorCoordinator

+1 (non-binding) Best regards, Weijie Mason Chen 于2023年2月7日周二 10:11写道： > +1 (non-binding) > > Best, > Mason > > > On Thu, Feb 2, 2023 at 6:03 PM Leonard Xu wrote: > > > +1 > > > > Best, > > Leonard > > > > > On Feb 3, 2023, at 9:49 AM, Dong Lin wrote: > > > > > > +1 > > > > > > On Thu, Feb

Re: [ANNOUNCE] New Apache Flink Committer - Jing Ge

Congratulations Jing! Best regards, Weijie Jingsong Li 于2023年2月14日周二 15:54写道： > Congratulations Jing! > > Best, > Jingsong > > On Tue, Feb 14, 2023 at 3:50 PM godfrey he wrote: > > > > Hi everyone, > > > > On behalf of the PMC, I'm very happy to announce Jing Ge as a new Flink > > committer.

Re: [ANNOUNCE] New Apache Flink PMC Member - Dong Lin

Congratulations Dong! Well deserved~ Best regards, Weijie Samrat Deb 于2023年2月16日周四 16:12写道： > Congratulations , Dong! > > On Thu, Feb 16, 2023 at 1:39 PM Jing Ge > wrote: > > > Congrats, Dong! > > > > On Thu, Feb 16, 2023 at 8:49 AM Martijn Visser > > > wrote: > > > > > Congratulations Dong

Re: [DISCUSS] Flink minor version support policy for old releases

Thanks Danny for the proposal~ +1 for this. In particular, we still have some users using relatively early versions of flink. Best regards, Weijie yuxia 于2023年2月20日周一 14:51写道： > +1 > Thanks for the proposal. > > Best regards, > Yuxia > > - 原始邮件 - > 发件人: "Weihua Hu" > 收件人: "dev" > 发

Re: [ANNOUNCE] New Apache Flink Committer - Rui Fan

Congrats, Rui! Best regards, Weijie Leonard Xu 于2023年2月21日周二 11:03写道： > Congratulations, Rui! > > Best, > Leonard > > > On Feb 21, 2023, at 9:50 AM, Matt Wang wrote: > > > > Congrats Rui > > > > > > -- > > > > Best, > > Matt Wang > > > > > > Replied Message > > | From | yuxia | > >

Re: [ANNOUNCE] New Apache Flink Committer - Anton Kalashnikov

Congratulations, Anton! Best regards, Weijie Leonard Xu 于2023年2月21日周二 11:02写道： > Congratulations, Anton! > > Best, > Leonard > > > > On Feb 21, 2023, at 10:02 AM, Rui Fan wrote: > > > > Congratulations, Anton! > > > > Best, > > Rui Fan > > > > On Tue, Feb 21, 2023 at 9:23 AM yuxia > wrote:

Re: [ANNOUNCE] New Apache Flink Committer - Sergey Nuyanzin

Congratulations, Sergey~ Best regards, Weijie Jing Ge 于2023年2月21日周二 20:52写道： > congrats Sergey! > > On Tue, Feb 21, 2023 at 1:15 PM Matthias Pohl > wrote: > > > Congratulations, Sergey! Good job & well-deserved! :) > > > > On Tue, Feb 21, 2023 at 1:03 PM yuxia > wrote: > > > > > Congratulat

Re: [ANNOUNCE] Flink project website is now powered by Hugo

Thanks Martijn for your great work. Best regards, Weijie Jingsong Li 于2023年2月24日周五 09:49写道： > Thanks Martijn! > > On Fri, Feb 24, 2023 at 9:46 AM yuxia wrote: > > > > Thanks Martijn for your work. > > > > Best regards, > > Yuxia > > > > - 原始邮件 - > > 发件人: "Jing Ge" > > 收件人: "dev" >

Re: [VOTE] Flink minor version support policy for old releases

Thanks Danny for bring this. +1 (non-binding) Best regards, Weijie Jing Ge 于2023年2月27日周一 20:23写道： > +1 (non-binding) > > BTW, should we follow the content style [1] to describe the new rule using > 1.2.x, 1.1.y, 1.1.z? > > [1] https://flink.apache.org/downloads/#update-policy-for-old-release

Re: [DISCUSS] FLIP-298: Unifying the Implementation of SlotManager

Thanks Weihua for preparing this FLIP. This FLIP overall looks reasonable to me after updating as suggested by Matthias. I only have one small question about keeping some redundant task managers: In the fine-grained resource management, theoretically, it can support heterogeneous taskmanagers. Wh

Re: [DISCUSS] FLIP-298: Unifying the Implementation of SlotManager

t is we can adjust the meaning of redundant configuration > to redundant number of per resource type. These can be considered in > detail when we decide to support heterogeneous task managers. > > Best, > Weihua > > > On Sat, Mar 4, 2023 at 1:13 AM weijie guo > wrote

Re: [DISCUSS] FLIP-301: Hybrid Shuffle supports Remote Storage

Hi Yuxin, As one of the main contributors of hybrid shuffle, I am very happy to see this improvement. IMO, hybrid shuffle should gradually replace the default batch shuffle implementation, because it is theoretically a superset of blocking shuffle(i.e. SortMergeShuffle / BoundedBlockingShuffle).

Re: [Vote] FLIP-298: Unifying the Implementation of SlotManager

+1 (binding) Best regards, Weijie Shammon FY 于2023年3月10日周五 11:02写道： > Thanks weihua, +1 (non-binding) > > Best, > Shammon > > On Fri, Mar 10, 2023 at 10:32 AM Xintong Song > wrote: > > > +1 (binding) > > > > Best, > > > > Xintong > > > > > > > > On Thu, Mar 9, 2023 at 1:28 PM Weihua Hu wrot

Re: [ANNOUNCE] New Apache Flink Committer - Yuxia Luo

Congratulations, Yuxia Best regards, Weijie Geng Biao 于2023年3月13日周一 11:02写道： > Congrats, yuxia. > Best, > Biao Geng > > 获取 Outlook for iOS > > 发件人: Guowei Ma > 发送时间: Monday, March 13, 2023 10:54:24 AM > 收件人: dev@flink.apache.org > 主题:

Re: [VOTE] FLIP-293: Introduce Flink Jdbc Driver For Sql Gateway

+1 (binding) Best regards, Weijie Jacky Lau 于2023年3月15日周三 13:30写道： > +1 (non-binding) > it will make integrate with other tools convenient, like beeline/tableau > > Best Regards, > Jacky Lau > > Ran Tao 于2023年3月15日周三 13:11写道： > > > It's a very nice improvement. > > > > +1 (non-binding) > > >

Re: [VOTE] FLIP-301: Hybrid Shuffle supports Remote Storage

Thanks Yuxin for driving this. +1 (binding) Best regards, Weijie Junrui Lee 于2023年3月20日周一 14:57写道： > +1 (non-binding) > > Best regards, > Junrui > > Weihua Hu 于2023年3月20日周一 14:24写道： > > > +1 (non-binding) > > > > Best, > > Weihua > > > > > > On Mon, Mar 20, 2023 at 12:39 PM Wencong Liu > w

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

+1 (non-binding) 1. Built from the source code 2. Verified the signature and checksum 3. Ran both streaming/batch jobs on yarn 4. Checked website PR Best regards, Weijie Yun Tang 于2023年3月21日周二 14:07写道： > +1 (non-binding) > > > * Verified the signature of source.tgz and jar packages.

Re: [VOTE] FLIP-304: Pluggable Failure Enrichers

+1 (binding) Best regards, Weijie Zhu Zhu 于2023年4月21日周五 11:03写道： > +1 (binding) > > Thanks, > Zhu > > Anton Kalashnikov 于2023年4月20日周四 20:03写道： > > > > +1 (binding) > > > > > > Thanks for this FLIP Panos, LGTM. > > > > -- > > Best regards, > > Anton Kalashnikov > > > > On 20.04.23 13:44, Roma

Re: [DISCUSS] FLIP-408: [Umbrella] Introduce DataStream API V2

because it's understood > that > > you have to choose between processing time and event time. > > The other part of the reason is that it needs to work based on the task's > > mailbox thread model to avoid concurrency issues. Could you clarify the > second &g

Re: [DISCUSS] FLIP-409: DataStream V2 Building Blocks: DataStream, Partitioning and ProcessFunction

to one method. > > > > 3. The order of parameters in the current ProcessFunction is (record, > > context, output), while this FLIP proposes to change the order into > > (record, output, context). Is there any reason to make this change? > > > > 4. Why does this FLIP prop

Re: [DISCUSS] FLIP-409: DataStream V2 Building Blocks: DataStream, Partitioning and ProcessFunction

e concepts like ConnectedStreams. But we hope that streams will be more clearly defined in the DataStream API, otherwise we will end up going the same way as the original API, which you have to understand `JoinedStreams/ConnectedStreams` and so on. Best regards, Weijie weijie guo 于2024年1月30日周二 1

Re: [DISCUSS] FLIP-409: DataStream V2 Building Blocks: DataStream, Partitioning and ProcessFunction

el extension. Therefore, the framework must provide this functionality. Best regards, Weijie weijie guo 于2024年1月30日周二 11:45写道： > Hi Yunfeng, > > Thank you for your attention > > > 1. Will we provide any API to support choosing which input to consume > between the two inputs of T

Re: [DISCUSS] FLIP-410: Config, Context and Processing Timer Service of DataStream API V2

t; methods, would it be better to also add a general > > withConfig(configKey, configValue) method to the ProcessConfigurable > > interface? Adding a method for each configuration might harm the > > readability and compatibility of configurations. > > > > Looking forward to

Re: [DISCUSS] FLIP-410: Config, Context and Processing Timer Service of DataStream API V2

st. For extensibility, I have added the getMetricManager instead of getMetricGroup to RuntimeContext, we can use it to get the MetricGroup. Best regards, Weijie weijie guo 于2024年1月30日周二 13:45写道： > Thanks Yunfeng, > > Let me try to answer your question :) > > > 1. Would it b

Re: [DISCUSS] FLIP-409: DataStream V2 Building Blocks: DataStream, Partitioning and ProcessFunction

and I propose to devote a new sub-FLIP to this issue > later. > > We can easily provide the `getExecutionEnvironment(Configuration)` or > > `withConfiguration(Configuration)` method later. > > > > > I noticed that there are two `collect` methods in the Collector, > > o

Re: [DISCUSS] FLIP-410: Config, Context and Processing Timer Service of DataStream API V2

pport delete the timer. Best regards, Weijie weijie guo 于2024年1月30日周二 14:35写道： > Hi Xuannan, > > > 1. +1 to only use XXXParititionStream if users only need to use the > configurable PartitionStream. If there are use cases for both, > perhaps we could us

Re: Re: [DISCUSS] FLIP-331: Support EndOfStreamWindows and isOutputOnEOF operator attribute to optimize task deployment

Thanks Dong and Xuannan, The updated FLIP LGTM. Best regards, Weijie Xuannan Su 于2024年1月30日周二 11:10写道： > Hi all, > > Thanks for the comments and suggestions. If there are no further > comments, I will open the voting thread tomorrow. > > Best regards, > Xuannan > On Fri, Jan 26, 2024 at 3:1

  1   2   3   4   5   6   >