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

Congratulations, Leonard! Best, Yuxin Panagiotis Garefalakis 于2023年4月22日周六 08:08写道： > Congrats Leonard! > > On Fri, Apr 21, 2023 at 11:19 AM Ahmed Hamdy wrote: > > > Congratulations Leonard. > > Best Regards > > Ahmed > > > > On Fri, 21 Apr 2023 at 17:23, Samrat Deb wrote: > > > > >

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

Congratulations, Qingsheng! Best, Yuxin Ahmed Hamdy 于2023年4月22日周六 02:20写道： > Congratulations Qingsheng. > Best regards > Ahmed > > On Fri, 21 Apr 2023 at 17:22, Samrat Deb wrote: > > > congratulations ! > > > > On Fri, 21 Apr 2023 at 9:45 PM, David Morávek wrote: > > > > > Congratulations,

[ANNOUNCE] Apache Flink Kafka Connectors 3.0.0 released

The Apache Flink community is very happy to announce the release of Apache Flink Kafka Connectors 3.0.0. This release is compatible with the Apache Flink 1.17.x release series. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and

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

Congrats Leonard! On Fri, Apr 21, 2023 at 11:19 AM Ahmed Hamdy wrote: > Congratulations Leonard. > Best Regards > Ahmed > > On Fri, 21 Apr 2023 at 17:23, Samrat Deb wrote: > > > congratulations > > > > On Fri, 21 Apr 2023 at 9:44 PM, David Morávek wrote: > > > > > Congratulations, Leonard,

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

Happy to announce that FLIP-304 has been approved unanimously! Voting included 8 votes, out of which 6 were binding -- and no disapproving votes. * Piotr Nowojski (binding) * David Morávek (binding) * Hong Teoh * Roman Khachatryan (binding) * Anton Kalashnikov (binding) * Zhu Zhu (binding) *

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

Thanks for the replies everyone! Closing this vote now and following up with the result in a separate email. Panagiotis On Fri, Apr 21, 2023 at 4:23 AM Weihua Hu wrote: > +1 (non-binding) > > Best, > Weihua > > > On Fri, Apr 21, 2023 at 4:00 PM weijie guo > wrote: > > > +1 (binding) > > > >

[jira] [Created] (FLINK-31880) Bad Test in OrcColumnarRowSplitReaderTest

Kurt Ostfeld created FLINK-31880: Summary: Bad Test in OrcColumnarRowSplitReaderTest Key: FLINK-31880 URL: https://issues.apache.org/jira/browse/FLINK-31880 Project: Flink Issue Type: Bug

[DISCUSS] FLINK-31873: Add setMaxParallelism to the DataStreamSink Class

Hi there devs, I would like to start a discussion thread for FLINK-31873[1]. We are in the processing of enabling Flink reactive mode as the default scheduling mode. While reading configuration docs [2] (I believe it was also mentioned during one of the training sessions during Flink Forward

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

Congratulations Qingsheng. Best regards Ahmed On Fri, 21 Apr 2023 at 17:22, Samrat Deb wrote: > congratulations ! > > On Fri, 21 Apr 2023 at 9:45 PM, David Morávek wrote: > > > Congratulations, Qingsheng, well deserved! > > > > Best, > > D. > > > > On Fri 21. 4. 2023 at 16:41, Feng Jin wrote:

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

Congratulations Leonard. Best Regards Ahmed On Fri, 21 Apr 2023 at 17:23, Samrat Deb wrote: > congratulations > > On Fri, 21 Apr 2023 at 9:44 PM, David Morávek wrote: > > > Congratulations, Leonard, well deserved! > > > > Best, > > D. > > > > On Fri 21. 4. 2023 at 16:40, Feng Jin wrote: > > >

[jira] [Created] (FLINK-31879) org.apache.avro.util.Utf8 cannot be serialized with avro when used in state

Feroze Daud created FLINK-31879: --- Summary: org.apache.avro.util.Utf8 cannot be serialized with avro when used in state Key: FLINK-31879 URL: https://issues.apache.org/jira/browse/FLINK-31879 Project:

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

congratulations On Fri, 21 Apr 2023 at 9:44 PM, David Morávek wrote: > Congratulations, Leonard, well deserved! > > Best, > D. > > On Fri 21. 4. 2023 at 16:40, Feng Jin wrote: > > > Congratulations, Leonard > > > > > > > > Best, > > Feng Jin > > > > On Fri, Apr 21, 2023 at 8:38 PM Mang

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

congratulations ! On Fri, 21 Apr 2023 at 9:45 PM, David Morávek wrote: > Congratulations, Qingsheng, well deserved! > > Best, > D. > > On Fri 21. 4. 2023 at 16:41, Feng Jin wrote: > > > Congratulations, Qingsheng > > > > > > > > Best, > > Feng Jin > > > > On Fri, Apr 21, 2023 at 8:39 PM

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

Congratulations, Qingsheng, well deserved! Best, D. On Fri 21. 4. 2023 at 16:41, Feng Jin wrote: > Congratulations, Qingsheng > > > > Best, > Feng Jin > > On Fri, Apr 21, 2023 at 8:39 PM Mang Zhang wrote: > > > Congratulations, Qingsheng. > > > > > > > > > > > > -- > > > > Best regards,

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

Congratulations, Leonard, well deserved! Best, D. On Fri 21. 4. 2023 at 16:40, Feng Jin wrote: > Congratulations, Leonard > > > > Best, > Feng Jin > > On Fri, Apr 21, 2023 at 8:38 PM Mang Zhang wrote: > > > Congratulations, Leonard. > > > > > > -- > > > > Best regards, > > Mang Zhang > >

Re: [VOTE] FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source

+1 On Thu, Apr 20, 2023 at 11:52 PM Hongshun Wang wrote: > Dear Flink Developers, > > > Thank you for providing feedback on FLIP-288: Enable Dynamic Partition > Discovery by Default in Kafka Source[1] on the discussion thread[2]. > > The goal of the FLIP is to enable partition discovery by

Re: [DISCUSS] FLIP-288:Enable Dynamic Partition Discovery by Default in Kafka Source

> I have already modified FLIP-288 to provide a newDiscoveryOffsetsInitializer in the KafkaSourceBuilder and KafkaSourceEnumerator. Users can use KafkaSourceBuilder#setNewDiscoveryOffsets to change the strategy for new partitions. Thanks for addressing my comment Hongshun. > Considering these

Re: [DISCUSS] FLIP-287: Extend Sink#InitContext to expose ExecutionConfig and JobID

Do we have to introduce `InitContext#createSerializer(TypeInformation)` which returns TypeSerializer, or is it sufficient to only provide `InitContext#createInputSerializer()` which returns TypeSerializer? I had the impression that buffering sinks like JDBC only need the latter. @Joao, could you

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

Congratulations, Qingsheng Best, Feng Jin On Fri, Apr 21, 2023 at 8:39 PM Mang Zhang wrote: > Congratulations, Qingsheng. > > > > > > -- > > Best regards, > Mang Zhang > > > > > > At 2023-04-21 19:50:02, "Jark Wu" wrote: > >Hi everyone, > > > >We are thrilled to announce that Qingsheng

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

Congratulations, Leonard Best, Feng Jin On Fri, Apr 21, 2023 at 8:38 PM Mang Zhang wrote: > Congratulations, Leonard. > > > -- > > Best regards, > Mang Zhang > > > > > > At 2023-04-21 19:47:52, "Jark Wu" wrote: > >Hi everyone, > > > >We are thrilled to announce that Leonard Xu has

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

Congratulations, Qingsheng. -- Best regards, Mang Zhang At 2023-04-21 19:50:02, "Jark Wu" wrote: >Hi everyone, > >We are thrilled to announce that Qingsheng Ren has joined the Flink PMC! > >Qingsheng has been contributing to Apache Flink for a long time. He is the >core contributor and

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

Congratulations, Leonard. -- Best regards, Mang Zhang At 2023-04-21 19:47:52, "Jark Wu" wrote: >Hi everyone, > >We are thrilled to announce that Leonard Xu has joined the Flink PMC! > >Leonard has been an active member of the Apache Flink community for many >years and became a committer

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

Congratulations, Leonard. Best regards, Yuxia - 原始邮件 - 发件人: "Jiabao Sun" 收件人: "dev" , "Jark Wu" 发送时间: 星期五, 2023年 4 月 21日 下午 7:52:08 主题: Re: [ANNOUNCE] New Apache Flink PMC Member - Leonard Xu Congratulations, Leonard. Best, Jiabao > 2023年4月21日 下午7:47，Jark Wu 写道： > > Hi everyone,

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

Congratulations, Qingsheng. Best, Jiabao > 2023年4月21日 下午7:50，Jark Wu 写道： > > Hi everyone, > > We are thrilled to announce that Qingsheng Ren has joined the Flink PMC! > > Qingsheng has been contributing to Apache Flink for a long time. He is the > core contributor and maintainer of the

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

Congratulations, Leonard. Best, Jiabao > 2023年4月21日 下午7:47，Jark Wu 写道： > > Hi everyone, > > We are thrilled to announce that Leonard Xu has joined the Flink PMC! > > Leonard has been an active member of the Apache Flink community for many > years and became a committer in Nov 2021. He has

[ANNOUNCE] New Apache Flink PMC Member - Qingsheng Ren

Hi everyone, We are thrilled to announce that Qingsheng Ren has joined the Flink PMC! Qingsheng has been contributing to Apache Flink for a long time. He is the core contributor and maintainer of the Kafka connector and flink-cdc-connectors, bringing users stability and ease of use in both

[ANNOUNCE] New Apache Flink PMC Member - Leonard Xu

Hi everyone, We are thrilled to announce that Leonard Xu has joined the Flink PMC! Leonard has been an active member of the Apache Flink community for many years and became a committer in Nov 2021. He has been involved in various areas of the project, from code contributions to community

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

+1 (non-binding) Best, Weihua On Fri, Apr 21, 2023 at 4:00 PM weijie guo wrote: > +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) > > > > > > >

Re: [DISCUSS] FLIP-287: Extend Sink#InitContext to expose ExecutionConfig and JobID

Good point! @Gordon Introducing an `InitContext#createSerializer(TypeInformation)` looks a better option to me, so we do not need to introduce an unmodifiable `ExecutionConfig` at this moment. Hope that we can make `ExecutionConfig` a read-only interface in Flink 2.0. It is exposed in

Off for a week

Hi all, Just to let you know, I'll be off and unresponsive for a week starting tonight. Best Etienne

Re: [VOTE] Release flink-connector-kafka 3.0.0 for Flink 1.17, release candidate #2

Thanks for driving the release Gordon! -Max On Fri, Apr 21, 2023 at 12:33 AM Tzu-Li (Gordon) Tai wrote: > > We have unanimously approved this release. > > There are 6 approving votes, 3 of which are binding: > > * Alexander Sorokoumov > * Martijn Visser (binding) > * Tzu-Li (Gordon) Tai

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,

[jira] [Created] (FLINK-31878) Fix the wrong name of PauseOrResumeSplitsTask#toString in connector fetcher

Yuxin Tan created FLINK-31878: - Summary: Fix the wrong name of PauseOrResumeSplitsTask#toString in connector fetcher Key: FLINK-31878 URL: https://issues.apache.org/jira/browse/FLINK-31878 Project:

[VOTE] FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source

Dear Flink Developers, Thank you for providing feedback on FLIP-288: Enable Dynamic Partition Discovery by Default in Kafka Source[1] on the discussion thread[2]. The goal of the FLIP is to enable partition discovery by default and set EARLIEST offset strategy for later discovered partitions.