Re: [ANNOUNCE] New Apache Flink Committer - Fabian Paul

Thanks for the warm welcome, I am looking forward to continuing working with you all. Best, Fabian

[jira] [Created] (FLINK-24918) Support to specify the data dir for state benchmark

Aitozi created FLINK-24918: -- Summary: Support to specify the data dir for state benchmark Key: FLINK-24918 URL: https://issues.apache.org/jira/browse/FLINK-24918 Project: Flink Issue Type:

Re: [ANNOUNCE] New Apache Flink Committer - Leonard Xu

Congratulations Leonard! Best, Yun -- From:Terry Wang Send Time:2021 Nov. 16 (Tue.) 14:27 To:dev Cc:Dawid Wysakowicz Subject:Re: [ANNOUNCE] New Apache Flink Committer - Leonard Xu Congratulations, Leonard Xu! Well deserved!

[jira] [Created] (FLINK-24917) YARNSessionFIFOSecuredITCase hangs on azure

Yun Gao created FLINK-24917: --- Summary: YARNSessionFIFOSecuredITCase hangs on azure Key: FLINK-24917 URL: https://issues.apache.org/jira/browse/FLINK-24917 Project: Flink Issue Type: Bug

Re: [DISCUSS] Definition of Done for Apache Flink

Hi Joe, thank you for starting this discussion. Having a common agreement on what to expect from a PR for it to be merged is very much a worthwhile goal. I'm slightly worried about the addition to the PR template. We shouldn't make opening PRs even more difficult (unless it adds sufficient

[jira] [Created] (FLINK-24916) AvroExternalJarProgramITCase JVM crash on Azure

Yun Gao created FLINK-24916: --- Summary: AvroExternalJarProgramITCase JVM crash on Azure Key: FLINK-24916 URL: https://issues.apache.org/jira/browse/FLINK-24916 Project: Flink Issue Type: Bug

Re: [ANNOUNCE] New Apache Flink Committer - Fabian Paul

Congrats Fabian! Best, Paul Lam > 2021年11月16日 11:26，Zhilong Hong 写道： > > Congratulations, Fabian! > > Best regards, > Zhilong Hong > > On Tue, Nov 16, 2021 at 10:19 AM Yangze Guo wrote: > >> Congrats & well deserved! >> >> Best, >> Yangze Guo >> >> On Tue, Nov 16, 2021 at 10:18 AM Jing

Re: [ANNOUNCE] New Apache Flink Committer - Leonard Xu

Congratulations, Leonard Xu! Well deserved! Best, Terry Wang > 2021年11月16日 下午1:59，OpenInx 写道： > > Congrats, Leonard! > > On Tue, Nov 16, 2021 at 12:10 AM Leonard Xu wrote: > >> Thank you all, it’s an honor to work in our community with everyone. >> >> I will continue to contribute to

Re: [ANNOUNCE] New Apache Flink Committer - Leonard Xu

Congrats, Leonard! On Tue, Nov 16, 2021 at 12:10 AM Leonard Xu wrote: > Thank you all, it’s an honor to work in our community with everyone. > > I will continue to contribute to the Flink community and Flink > ecology(e.g.Flink CDC Connectors). > > Best, > Leonard > > > > > 在

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

Congrats Jing! On Tue, Nov 16, 2021 at 11:59 AM Terry Wang wrote: > Congratulations, Jing! > Well deserved! > > Best, > Terry Wang > > > > > 2021年11月16日 上午11:27，Zhilong Hong 写道： > > > > Congratulations, Jing! > > > > Best regards, > > Zhilong Hong > > > > On Mon, Nov 15, 2021 at 9:41 PM

[jira] [Created] (FLINK-24915) StreamElementSerializer#deserialize(StreamElement reuse, DataInputView source) forgets to handle tag == TAG_STREAM_STATUS

bx123 created FLINK-24915: - Summary: StreamElementSerializer#deserialize(StreamElement reuse, DataInputView source) forgets to handle tag == TAG_STREAM_STATUS Key: FLINK-24915 URL:

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

Congratulations, Jing! Well deserved! Best, Terry Wang > 2021年11月16日 上午11:27，Zhilong Hong 写道： > > Congratulations, Jing! > > Best regards, > Zhilong Hong > > On Mon, Nov 15, 2021 at 9:41 PM Martijn Visser > wrote: > >> Congratulations Jing! >> >> On Mon, 15 Nov 2021 at 14:39, Timo

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

Congratulations, Jing! Best regards, Zhilong Hong On Mon, Nov 15, 2021 at 9:41 PM Martijn Visser wrote: > Congratulations Jing! > > On Mon, 15 Nov 2021 at 14:39, Timo Walther wrote: > > > Hi everyone, > > > > On behalf of the PMC, I'm very happy to announce Jing Zhang as a new > > Flink

Re: [ANNOUNCE] New Apache Flink Committer - Fabian Paul

Congratulations, Fabian! Best regards, Zhilong Hong On Tue, Nov 16, 2021 at 10:19 AM Yangze Guo wrote: > Congrats & well deserved! > > Best, > Yangze Guo > > On Tue, Nov 16, 2021 at 10:18 AM Jing Zhang wrote: > > > > Congratulations Fabian! > > > > Best, > > Jing Zhang > > > > Yuepeng Pan

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

Congrats Jing! Best, Paul Lam > 2021年11月16日 10:48，Yun Tang 写道： > > Congratulations, Jing! > > Best > Yun Tang > > From: Yuepeng Pan > Sent: Tuesday, November 16, 2021 10:12 > To: dev@flink.apache.org > Cc: beyond1...@gmail.com > Subject: Re:[ANNOUNCE] New

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

Congratulations, Jing! Best Yun Tang From: Yuepeng Pan Sent: Tuesday, November 16, 2021 10:12 To: dev@flink.apache.org Cc: beyond1...@gmail.com Subject: Re:[ANNOUNCE] New Apache Flink Committer - Jing Zhang Congrats. Best, Yuepeng Pan At

[jira] [Created] (FLINK-24914) Support implicit type conversion in SQL like "select int_field = varchar_field"

xuyang created FLINK-24914: -- Summary: Support implicit type conversion in SQL like "select int_field = varchar_field" Key: FLINK-24914 URL: https://issues.apache.org/jira/browse/FLINK-24914 Project: Flink

Re: [ANNOUNCE] New Apache Flink Committer - Fabian Paul

Congrats & well deserved! Best, Yangze Guo On Tue, Nov 16, 2021 at 10:18 AM Jing Zhang wrote: > > Congratulations Fabian! > > Best, > Jing Zhang > > Yuepeng Pan 于2021年11月16日周二 上午10:16写道： > > > Congratulations Fabian! > > > > Best, > > Yuepeng Pan > > > > At 2021-11-15 21:17:13, "Arvid Heise"

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

Congrats & well deserved! Best, Yangze Guo On Tue, Nov 16, 2021 at 10:14 AM Yuepeng Pan wrote: > > Congrats. > > > Best, > Yuepeng Pan > > > > > > > > > > > > At 2021-11-15 21:39:47, "Timo Walther" wrote: > >Hi everyone, > > > >On behalf of the PMC, I'm very happy to announce Jing Zhang as a

Re: [ANNOUNCE] New Apache Flink Committer - Fabian Paul

Congratulations Fabian! Best, Jing Zhang Yuepeng Pan 于2021年11月16日周二 上午10:16写道： > Congratulations Fabian! > > Best, > Yuepeng Pan > > At 2021-11-15 21:17:13, "Arvid Heise" wrote: > >Hi everyone, > > > >On behalf of the PMC, I'm very happy to announce Fabian Paul as a new > Flink > >committer.

Re:[ANNOUNCE] New Apache Flink Committer - Fabian Paul

Congratulations Fabian! Best, Yuepeng Pan At 2021-11-15 21:17:13, "Arvid Heise" wrote: >Hi everyone, > >On behalf of the PMC, I'm very happy to announce Fabian Paul as a new Flink >committer. > >Fabian Paul has been actively improving the connector ecosystem by >migrating Kafka and

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

Congrats. Best, Yuepeng Pan At 2021-11-15 21:39:47, "Timo Walther" wrote: >Hi everyone, > >On behalf of the PMC, I'm very happy to announce Jing Zhang as a new >Flink committer. > >Jing has been very active in the Flink community esp. in the Table/SQL >area for quite some time: 81

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

Congratulations Jing! Best, Shengkai wenlong.lwl 于2021年11月16日周二 上午10:02写道： > Congratulations Jing！ > > Best， > Wenlong > > On Tue, 16 Nov 2021 at 09:54, Kurt Young wrote: > > > Congrats Jing! > > > > Best, > > Kurt > > > > On Tue, Nov 16, 2021 at 9:52 AM Xintong Song > > wrote: > > > > >

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

Congratulations Jing！ Best， Wenlong On Tue, 16 Nov 2021 at 09:54, Kurt Young wrote: > Congrats Jing! > > Best, > Kurt > > On Tue, Nov 16, 2021 at 9:52 AM Xintong Song > wrote: > > > Congratulations~! > > > > Thank you~ > > > > Xintong Song > > > > > > > > On Tue, Nov 16, 2021 at 9:50 AM Dian

Re: [ANNOUNCE] New Apache Flink Committer - Fabian Paul

Congratulations Fabian! Best, Godfrey Xintong Song 于2021年11月16日周二 上午9:53写道： > > Congratulations~! > > Thank you~ > > Xintong Song > > > > On Tue, Nov 16, 2021 at 9:47 AM Qingsheng Ren wrote: > > > Congratulations Fabian! > > > > -- > > Best Regards, > > > > Qingsheng Ren > > Email:

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

Congrats Jing! Best, Kurt On Tue, Nov 16, 2021 at 9:52 AM Xintong Song wrote: > Congratulations~! > > Thank you~ > > Xintong Song > > > > On Tue, Nov 16, 2021 at 9:50 AM Dian Fu wrote: > > > Congratulations! > > > > Regards, > > Dian > > > > On Tue, Nov 16, 2021 at 9:48 AM godfrey he wrote:

Re: [ANNOUNCE] New Apache Flink Committer - Fabian Paul

Congratulations~! Thank you~ Xintong Song On Tue, Nov 16, 2021 at 9:47 AM Qingsheng Ren wrote: > Congratulations Fabian! > > -- > Best Regards, > > Qingsheng Ren > Email: renqs...@gmail.com > On Nov 15, 2021, 9:17 PM +0800, Arvid Heise , wrote: > > Hi everyone, > > > > On behalf of the PMC,

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

Congratulations~! Thank you~ Xintong Song On Tue, Nov 16, 2021 at 9:50 AM Dian Fu wrote: > Congratulations! > > Regards, > Dian > > On Tue, Nov 16, 2021 at 9:48 AM godfrey he wrote: > > > Congrats & well deserved, Jing! > > > > Best, > > Godfrey > > > > Leonard Xu 于2021年11月16日周二

Re: [ANNOUNCE] New Apache Flink Committer - Fabian Paul

Congratulations! Regards, Dian On Tue, Nov 16, 2021 at 9:47 AM Qingsheng Ren wrote: > Congratulations Fabian! > > -- > Best Regards, > > Qingsheng Ren > Email: renqs...@gmail.com > On Nov 15, 2021, 9:17 PM +0800, Arvid Heise , wrote: > > Hi everyone, > > > > On behalf of the PMC, I'm very

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

Congratulations! Regards, Dian On Tue, Nov 16, 2021 at 9:48 AM godfrey he wrote: > Congrats & well deserved, Jing! > > Best, > Godfrey > > Leonard Xu 于2021年11月16日周二 上午12:11写道： > > > > Congratulations Jing! Well Deserved. > > > > > > > 在 2021年11月15日，22:30，Dawid Wysakowicz 写道： > > > > > >

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

Congrats & well deserved, Jing! Best, Godfrey Leonard Xu 于2021年11月16日周二 上午12:11写道： > > Congratulations Jing! Well Deserved. > > > > 在 2021年11月15日，22:30，Dawid Wysakowicz 写道： > > > > Congrats! > > > > On 15/11/2021 14:39, Timo Walther wrote: > >> Hi everyone, > >> > >> On behalf of the PMC, I'm

Re: [ANNOUNCE] New Apache Flink Committer - Fabian Paul

Congratulations Fabian! -- Best Regards, Qingsheng Ren Email: renqs...@gmail.com On Nov 15, 2021, 9:17 PM +0800, Arvid Heise , wrote: > Hi everyone, > > On behalf of the PMC, I'm very happy to announce Fabian Paul as a new Flink > committer. > > Fabian Paul has been actively improving the

Re: [DISCUSS] Definition of Done for Apache Flink

Hi Joe, Thanks for starting this thread! It seems the proposal emphasizes documentation and test coverage, which are normal practices in releasing a large software. It looks all good but the point is that how you'd like to apply it? We have a checklist in the PR template and @flinkbot will

[jira] [Created] (FLINK-24913) Upgrade KPL version in flink-connector-kinesis to support ARM

Melody created FLINK-24913: -- Summary: Upgrade KPL version in flink-connector-kinesis to support ARM Key: FLINK-24913 URL: https://issues.apache.org/jira/browse/FLINK-24913 Project: Flink Issue

[jira] [Created] (FLINK-24912) Migrate state processor API to DataStream API

Seth Wiesman created FLINK-24912: Summary: Migrate state processor API to DataStream API Key: FLINK-24912 URL: https://issues.apache.org/jira/browse/FLINK-24912 Project: Flink Issue Type:

[jira] [Created] (FLINK-24911) Enable line numbers in SQL Client

Sergey Nuyanzin created FLINK-24911: --- Summary: Enable line numbers in SQL Client Key: FLINK-24911 URL: https://issues.apache.org/jira/browse/FLINK-24911 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-24910) Propagate the Calcite parser config to SQL Client

Sergey Nuyanzin created FLINK-24910: --- Summary: Propagate the Calcite parser config to SQL Client Key: FLINK-24910 URL: https://issues.apache.org/jira/browse/FLINK-24910 Project: Flink

[jira] [Created] (FLINK-24909) SQL syntax highlighting in SQL Client

Sergey Nuyanzin created FLINK-24909: --- Summary: SQL syntax highlighting in SQL Client Key: FLINK-24909 URL: https://issues.apache.org/jira/browse/FLINK-24909 Project: Flink Issue Type:

[jira] [Created] (FLINK-24908) Improve SQL Error description for SQL Client

Sergey Nuyanzin created FLINK-24908: --- Summary: Improve SQL Error description for SQL Client Key: FLINK-24908 URL: https://issues.apache.org/jira/browse/FLINK-24908 Project: Flink Issue

[jira] [Created] (FLINK-24907) Enable Side Output for late events on IntervalJoins

Andrew Straussman created FLINK-24907: - Summary: Enable Side Output for late events on IntervalJoins Key: FLINK-24907 URL: https://issues.apache.org/jira/browse/FLINK-24907 Project: Flink

Re: [ANNOUNCE] New Apache Flink Committer - Fabian Paul

Congratulations Fabian. > On 15.11.2021, at 18:58, David Morávek wrote: > > Congratulations Fabian!! > > Best, > D. > > On Mon, Nov 15, 2021 at 5:10 PM Leonard Xu wrote: > >> Congratulations Fabian! >> >>> 在 2021年11月15日，22:50，Roman Khachatryan 写道： >>> >>> Congratulations Fabian! >>> >>>

1.15 release cycle feature overview

Dear Flink Community. In case you want to contribute something to the 1.15 Flink release I’d kindly asking you to add your features/changes to the 1.15 release overview page [1]. I, as one of the release managers, will keep track of the state of the changes. In case you have questions or need

[DISCUSS] Definition of Done for Apache Flink

Dear Flink Community, We as the release managers of the 1.15 release are suggesting to introduce a “Definition of Done". Let me elaborate a bit on the reasons: * During the release process for 1.14 the stability of master was sometimes in a state that made contributing to Apache Flink a bad

Re: [DISCUSS] Update Policy for old releases

Nice to see this discussion! If we make Flink upgrades easy, why would users not want to upgrade? I think most hesitation today stems from the fact that X.Y.0 releases tend to break downstream in one way or the other due to unexpected upstream changes. If so, it would be nice if we could address

Re: [ANNOUNCE] New Apache Flink Committer - Fabian Paul

Congratulations Fabian!! Best, D. On Mon, Nov 15, 2021 at 5:10 PM Leonard Xu wrote: > Congratulations Fabian! > > > 在 2021年11月15日，22:50，Roman Khachatryan 写道： > > > > Congratulations Fabian! > > > > Regards, > > Roman > > > > On Mon, Nov 15, 2021 at 3:26 PM Dawid Wysakowicz > wrote: > >> > >>

Re: [DISCUSS] Conventions on assertions to use in tests

> It is a bit unfortunate that we have tests that follow different patterns. This, however, is mainly due to organic growth. I think the community started with Junit4, then we chose to use Hamcrest because of its better expressiveness. That is fine, I'm sorry if my mail felt like a rant :) >

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

Congratulations Jing! Well Deserved. > 在 2021年11月15日，22:30，Dawid Wysakowicz 写道： > > Congrats! > > On 15/11/2021 14:39, Timo Walther wrote: >> Hi everyone, >> >> On behalf of the PMC, I'm very happy to announce Jing Zhang as a new >> Flink committer. >> >> Jing has been very active in the

Re: [ANNOUNCE] New Apache Flink Committer - Fabian Paul

Congratulations Fabian! > 在 2021年11月15日，22:50，Roman Khachatryan 写道： > > Congratulations Fabian! > > Regards, > Roman > > On Mon, Nov 15, 2021 at 3:26 PM Dawid Wysakowicz > wrote: >> >> Congratulations Fabian! >> >> On 15/11/2021 15:22, Marios Trivyzas wrote: >>> Congrats Fabian! >>> >>>

Re: [ANNOUNCE] New Apache Flink Committer - Leonard Xu

Thank you all, it’s an honor to work in our community with everyone. I will continue to contribute to the Flink community and Flink ecology(e.g.Flink CDC Connectors). Best, Leonard > 在 2021年11月15日，22:27，Dawid Wysakowicz 写道： > > Congrats! > > On 12/11/2021 05:12, Jark Wu wrote: >> Hi

[jira] [Created] (FLINK-24906) Improve CSV format handling and support

Martijn Visser created FLINK-24906: -- Summary: Improve CSV format handling and support Key: FLINK-24906 URL: https://issues.apache.org/jira/browse/FLINK-24906 Project: Flink Issue Type:

[jira] [Created] (FLINK-24905) KDS implementation of Async Sink Table API

Zichen Liu created FLINK-24905: -- Summary: KDS implementation of Async Sink Table API Key: FLINK-24905 URL: https://issues.apache.org/jira/browse/FLINK-24905 Project: Flink Issue Type: New

Re: [ANNOUNCE] New Apache Flink Committer - Fabian Paul

Congratulations Fabian! Regards, Roman On Mon, Nov 15, 2021 at 3:26 PM Dawid Wysakowicz wrote: > > Congratulations Fabian! > > On 15/11/2021 15:22, Marios Trivyzas wrote: > > Congrats Fabian! > > > > On Mon, Nov 15, 2021 at 3:02 PM Francesco Guardiani > > > > wrote: > > > >> Congratulations

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

Congrats! On 15/11/2021 14:39, Timo Walther wrote: > Hi everyone, > > On behalf of the PMC, I'm very happy to announce Jing Zhang as a new > Flink committer. > > Jing has been very active in the Flink community esp. in the Table/SQL > area for quite some time: 81 PRs [1] in total and is also

Re: [ANNOUNCE] New Apache Flink Committer - Yangze Guo

Congrats! On 15/11/2021 15:22, Marios Trivyzas wrote: > Congrats Yangze! > > On Mon, Nov 15, 2021 at 1:34 PM Martijn Visser > wrote: > >> Congrats Yangze! >> >> On Mon, 15 Nov 2021 at 09:13, Yangze Guo wrote: >> >>> Thank you all very much! >>> It's my honor to work with you in such a great

Re: [ANNOUNCE] New Apache Flink Committer - Leonard Xu

Congrats! On 12/11/2021 05:12, Jark Wu wrote: > Hi everyone, > > On behalf of the PMC, I'm very happy to announce Leonard Xu as a new Flink > committer. > > Leonard has been a very active contributor for more than two year, authored > 150+ PRs and reviewed many PRs which is quite outstanding. >

Re: [ANNOUNCE] New Apache Flink Committer - Fabian Paul

Congratulations Fabian! On 15/11/2021 15:22, Marios Trivyzas wrote: > Congrats Fabian! > > On Mon, Nov 15, 2021 at 3:02 PM Francesco Guardiani > wrote: > >> Congratulations Fabian! >> >> On Mon, Nov 15, 2021 at 2:29 PM Yun Gao >> wrote: >> >>> Congratulations Fabian! >>> >>> Best, >>> Yun >>>

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

Congratulations Jing! On Mon, Nov 15, 2021 at 10:23 PM Marios Trivyzas wrote: > Congrats Jing! > > On Mon, Nov 15, 2021 at 3:20 PM Till Rohrmann > wrote: > > > Congratulations Jing :-) > > > > Cheers, > > Till > > > > On Mon, Nov 15, 2021 at 2:48 PM Martijn Visser > > wrote: > > > > >

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

Congratulations Jing! Best, Yun --Original Mail -- Sender:Till Rohrmann Send Date:Mon Nov 15 22:20:52 2021 Recipients:dev CC:JING ZHANG Subject:Re: [ANNOUNCE] New Apache Flink Committer - Jing Zhang Congratulations Jing :-) Cheers, Till On Mon, Nov 15,

Re: [ANNOUNCE] New Apache Flink Committer - Yangze Guo

Congrats Yangze! On Mon, Nov 15, 2021 at 1:34 PM Martijn Visser wrote: > Congrats Yangze! > > On Mon, 15 Nov 2021 at 09:13, Yangze Guo wrote: > > > Thank you all very much! > > It's my honor to work with you in such a great community. > > > > Best, > > Yangze Guo > > > > On Mon, Nov 15, 2021

Re: Re: [ANNOUNCE] New Apache Flink Committer - Fabian Paul

Congrats Fabian! On Mon, Nov 15, 2021 at 3:02 PM Francesco Guardiani wrote: > Congratulations Fabian! > > On Mon, Nov 15, 2021 at 2:29 PM Yun Gao > wrote: > > > Congratulations Fabian! > > > > Best, > > Yun > > --Original Mail -- > > Sender:Ingo Bürk > > Send

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

Congrats Jing! On Mon, Nov 15, 2021 at 3:20 PM Till Rohrmann wrote: > Congratulations Jing :-) > > Cheers, > Till > > On Mon, Nov 15, 2021 at 2:48 PM Martijn Visser > wrote: > > > Congratulations Jing! > > > > On Mon, 15 Nov 2021 at 14:39, Timo Walther wrote: > > > > > Hi everyone, > > > > >

Re: Re: [ANNOUNCE] New Apache Flink Committer - Fabian Paul

Congratulations Fabian :-) Cheers, Till On Mon, Nov 15, 2021 at 3:03 PM Francesco Guardiani wrote: > Congratulations Fabian! > > On Mon, Nov 15, 2021 at 2:29 PM Yun Gao > wrote: > > > Congratulations Fabian! > > > > Best, > > Yun > > --Original Mail -- > >

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

Congratulations Jing :-) Cheers, Till On Mon, Nov 15, 2021 at 2:48 PM Martijn Visser wrote: > Congratulations Jing! > > On Mon, 15 Nov 2021 at 14:39, Timo Walther wrote: > > > Hi everyone, > > > > On behalf of the PMC, I'm very happy to announce Jing Zhang as a new > > Flink committer. > > >

Re: Re: [ANNOUNCE] New Apache Flink Committer - Fabian Paul

Congratulations Fabian! On Mon, Nov 15, 2021 at 2:29 PM Yun Gao wrote: > Congratulations Fabian! > > Best, > Yun > --Original Mail -- > Sender:Ingo Bürk > Send Date:Mon Nov 15 21:27:36 2021 > Recipients:dev > CC: , > Subject:Re: [ANNOUNCE] New Apache Flink

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

Congratulations Jing! On Mon, 15 Nov 2021 at 14:39, Timo Walther wrote: > Hi everyone, > > On behalf of the PMC, I'm very happy to announce Jing Zhang as a new > Flink committer. > > Jing has been very active in the Flink community esp. in the Table/SQL > area for quite some time: 81 PRs [1] in

[ANNOUNCE] New Apache Flink Committer - Jing Zhang

Hi everyone, On behalf of the PMC, I'm very happy to announce Jing Zhang as a new Flink committer. Jing has been very active in the Flink community esp. in the Table/SQL area for quite some time: 81 PRs [1] in total and is also active on answering questions on the user mailing list. She is

[jira] [Created] (FLINK-24904) Add documentation for KDS Async Sink

Zichen Liu created FLINK-24904: -- Summary: Add documentation for KDS Async Sink Key: FLINK-24904 URL: https://issues.apache.org/jira/browse/FLINK-24904 Project: Flink Issue Type: New Feature

Re: Re: [ANNOUNCE] New Apache Flink Committer - Fabian Paul

Congratulations Fabian! Best, Yun --Original Mail -- Sender:Ingo Bürk Send Date:Mon Nov 15 21:27:36 2021 Recipients:dev CC: , Subject:Re: [ANNOUNCE] New Apache Flink Committer - Fabian Paul Congratulations, Fabian! On Mon, Nov 15, 2021 at 2:17 PM Arvid Heise

Re: [ANNOUNCE] New Apache Flink Committer - Fabian Paul

Congratulations Fabian! On Mon, 15 Nov 2021 at 14:27, Ingo Bürk wrote: > Congratulations, Fabian! > > On Mon, Nov 15, 2021 at 2:17 PM Arvid Heise wrote: > > > Hi everyone, > > > > On behalf of the PMC, I'm very happy to announce Fabian Paul as a new > Flink > > committer. > > > > Fabian Paul

Re: [ANNOUNCE] New Apache Flink Committer - Fabian Paul

Congratulations, Fabian! On Mon, Nov 15, 2021 at 2:17 PM Arvid Heise wrote: > Hi everyone, > > On behalf of the PMC, I'm very happy to announce Fabian Paul as a new Flink > committer. > > Fabian Paul has been actively improving the connector ecosystem by > migrating Kafka and ElasticSearch to

[ANNOUNCE] New Apache Flink Committer - Fabian Paul

Hi everyone, On behalf of the PMC, I'm very happy to announce Fabian Paul as a new Flink committer. Fabian Paul has been actively improving the connector ecosystem by migrating Kafka and ElasticSearch to the Sink interface and is currently driving FLIP-191 [1] to tackle the sink compaction

[jira] [Created] (FLINK-24903) AdaptiveSchedulerTest.testJobStatusListenerNotifiedOfJobStatusChanges unstable

Roman Khachatryan created FLINK-24903: - Summary: AdaptiveSchedulerTest.testJobStatusListenerNotifiedOfJobStatusChanges unstable Key: FLINK-24903 URL: https://issues.apache.org/jira/browse/FLINK-24903

Re: [ANNOUNCE] New Apache Flink Committer - Yangze Guo

Congrats Yangze! On Mon, 15 Nov 2021 at 09:13, Yangze Guo wrote: > Thank you all very much! > It's my honor to work with you in such a great community. > > Best, > Yangze Guo > > On Mon, Nov 15, 2021 at 2:08 PM Yang Wang wrote: > > > > Congratulations Yangze! > > > > Best, > > Yang > > > > Yu

[jira] [Created] (FLINK-24902) Port boolean <-> numeric casting logic to CastRule

Francesco Guardiani created FLINK-24902: --- Summary: Port boolean <-> numeric casting logic to CastRule Key: FLINK-24902 URL: https://issues.apache.org/jira/browse/FLINK-24902 Project: Flink

[jira] [Created] (FLINK-24901) Some further improvements of the pluggable shuffle framework

Yingjie Cao created FLINK-24901: --- Summary: Some further improvements of the pluggable shuffle framework Key: FLINK-24901 URL: https://issues.apache.org/jira/browse/FLINK-24901 Project: Flink

[jira] [Created] (FLINK-24900) Support to run multiple shuffle plugins in one session cluster

Yingjie Cao created FLINK-24900: --- Summary: Support to run multiple shuffle plugins in one session cluster Key: FLINK-24900 URL: https://issues.apache.org/jira/browse/FLINK-24900 Project: Flink

Re: [DISCUSS] Update Policy for old releases

Hi everyone, I want to second Stephan's points. I think that supporting LTS versions rather fights symptoms than addressing the underlying problem that are incompatible/behaviour changing changes between versions. I believe if we can address this problem, then our Flink users will probably

Re: Re: [DISCUSS] Improve the name and structure of job vertex and operator name for job

Hi, all, FYI the FLIP doc has been created ： https://cwiki.apache.org/confluence/display/FLINK/FLIP-195%3A+Improve+the+name+and+structure+of+vertex+and+operator+name+for+sql+job Best, Wenlong On Mon, 15 Nov 2021 at 11:41, wenlong.lwl wrote: > Hi all, > Thanks for the feedback, It seems that

[jira] [Created] (FLINK-24899) Enable data compression for blocking shuffle by default

Yingjie Cao created FLINK-24899: --- Summary: Enable data compression for blocking shuffle by default Key: FLINK-24899 URL: https://issues.apache.org/jira/browse/FLINK-24899 Project: Flink Issue

[jira] [Created] (FLINK-24898) Some further improvements of sort-shuffle

Yingjie Cao created FLINK-24898: --- Summary: Some further improvements of sort-shuffle Key: FLINK-24898 URL: https://issues.apache.org/jira/browse/FLINK-24898 Project: Flink Issue Type: Bug

Re: Flink support for OrderedListState

Hi Reuven, cc dev@flink.apache.org.  Jan On 11/12/21 04:35, Reuven Lax wrote: OrderedListState  was added to Beam over a year ago. To date it is only supported by the

Re: [DISCUSS] FLIP-188: Introduce Built-in Dynamic Table Storage

Hi Timo, > It would be great if we can add not only `Receive any type of changelog` but > also `Receive any type of datatype`. Nice, I think we can. > Please clarify whether the compact DDL is a synchronous or asynchrounous > operation in the API? So far all DDL was synchrounous. And only DML

[jira] [Created] (FLINK-24897) Enable application mode on YARN to use usrlib

Biao Geng created FLINK-24897: - Summary: Enable application mode on YARN to use usrlib Key: FLINK-24897 URL: https://issues.apache.org/jira/browse/FLINK-24897 Project: Flink Issue Type:

[DISCUSS] Allow user to unsubscribe by sending "Unsubscribe" directly to user mailing list

Hi devs! I've seen unsubscribe emails coming into the mailing lists now and then these days (both user and user-zh mailing lists). Instead of telling the user to send emails to some specific email addresses again and again, can we allow user to unsubscribe by sending "Unsubscribe" directly to

Re: [ANNOUNCE] Documentation now available at nightlies.apache.org

flink.apache.org/docs/1.14 never existed though and would also result in a 404. On 15/11/2021 09:21, Yu Li wrote: Thank you all for the efforts! However, it seems to me that https://flink.apache.org/docs/1.14/ will be redirected to https://nightlies.apache.org/flink/flink-docs-master/1.14/ and

[jira] [Created] (FLINK-24896) Failed to execute goal com.github.siom79.japicmp:japicmp-maven-plugin:0.11.0:cmp (default) on project flink-metrics-core

Yun Gao created FLINK-24896: --- Summary: Failed to execute goal com.github.siom79.japicmp:japicmp-maven-plugin:0.11.0:cmp (default) on project flink-metrics-core Key: FLINK-24896 URL:

[jira] [Created] (FLINK-24895) SqlTimestampSerializer#deserialize forgets to fully read from source when the record is null.

bx123 created FLINK-24895: - Summary: SqlTimestampSerializer#deserialize forgets to fully read from source when the record is null. Key: FLINK-24895 URL: https://issues.apache.org/jira/browse/FLINK-24895

[jira] [Created] (FLINK-24894) Flink on k8s, open the HA mode based on KubernetesHaServicesFactory ，When I deleted the job, the config map created under the HA mechanism was not deleted.

john created FLINK-24894: Summary: Flink on k8s, open the HA mode based on KubernetesHaServicesFactory ，When I deleted the job, the config map created under the HA mechanism was not deleted. Key: FLINK-24894 URL:

Re: Re: [VOTE] FLIP-174: Improve the WithParam interface

Hi everyone, We would like to update WithParams::set(...) to throw an IllegalArgumentException if the given Param instance is not defined on the WithParams instance. The reason is that there is no use-case where users will want to set a parameter that is not defined on the WithParams instance.

Re: [DISCUSS] FLIP-188: Introduce Built-in Dynamic Table Storage

Hi Stephan, ### about PK: > (6) Different consistency guarantees with PK and without PK > (7) Eventual Consistency Mode vs. Faster Checkpoints Let's clarify one thing first: For sink with PK, Flink SQL cannot generate complete changes (without UPDATE_BEFORE). - For

Re: [ANNOUNCE] Documentation now available at nightlies.apache.org

Thank you all for the efforts! However, it seems to me that https://flink.apache.org/docs/1.14/ will be redirected to https://nightlies.apache.org/flink/flink-docs-master/1.14/ and get a 404 error. The correct link to redirect to should be

Re: [ANNOUNCE] New Apache Flink Committer - Yangze Guo

Thank you all very much! It's my honor to work with you in such a great community. Best, Yangze Guo On Mon, Nov 15, 2021 at 2:08 PM Yang Wang wrote: > > Congratulations Yangze! > > Best, > Yang > > Yu Li 于2021年11月15日周一 下午2:01写道： >> >> Congratulations, Yangze! >> >> Best Regards, >> Yu >> >> >>

Re: Re: [VOTE] FLIP-173: Support DAG of algorithms

Hi everyone, We would like to make the following API changes to this FLIP: 1) Updates Stage's Java doc to say the following Every Stage subclass should implement a static method with signature "static T load(StreamExecutionEnvironment env, String path)", where T refers to the concrete subclass.