refactor StreamConfig

HI All: I am sorry about working with StreamConfig(https://github.com/apache/flink/pull/4241) which may conflicts with others' work before discussing. Motivation: A Task contains one or more operators with chainning, however configs of operator and task are all put in Stream

Re:refactor StreamConfig （Appending a picture）

I All: I am sorry about working with StreamConfig(https://github.com/apache/flink/pull/4241) which may conflicts with others' work before discussing. Motivation: A Task contains one or more operators with chainning, however configs of operator and task are all put in StreamC

Re:Re: refactor StreamConfig

Hi Aljoscha: Thanks a lot for your advice. I think I have not need to separate steps, because what I do is only that introducing OperatorConfig and moving the fields. StreamConfig still relys on an underlying Configuration which flows from client to the jobmanager and then to the tas

Re: Rolling policy when using StreamingFileSink for bulk-encoded output

On Fri, Jun 28, 2019 at 9:51 AM Ying Xu wrote: > Hi Kostas: > > I'd like to. The account used to file the JIRA does not have contributor > access yet . I had contributed a few Flink JIRAs in the past, using a very > similar but different account. Now I would like to consolidate

Re: [VOTE] Migrate to sponsored Travis account

+1 vino yang 于2019年7月4日周四 下午7:55写道： > +1 > > Dian Fu 于2019年7月4日周四 下午7:09写道： > > > +1. Thanks Chesnay and Bowen for pushing this forward. > > > > Regards, > > Dian > > > > > 在 2019年7月4日，下午6:28，zhijiang 写道： > > > > > > +1 and thanks for Chesnay' work on this. > > > > > > Best, > > > Zhijiang > >

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Congratulations Becket! Well deserved. Cheers, forward Kurt Young 于2019年7月18日周四 下午4:20写道： > Congrats Becket! > > Best, > Kurt > > > On Thu, Jul 18, 2019 at 4:12 PM JingsongLee .invalid> > wrote: > > > Congratulations Becket! > > > > Best, Jingsong Lee > > > > > >

Re: [DISCUSS] Setup a bui...@flink.apache.org mailing list for travis builds

+1 ,Thanks jark for the proposal. Best Forward Jark Wu 于2019年7月20日周六 下午12:14写道： > Hi all, > > As far as I know, currently, email notifications of Travis builds for > master branch are sent to the commit author when a build was just broken or > still is broken. And there is no email notifications

Re: [DISCUSS] Flink project bylaws

Big +1 on this. best forward Hequn Cheng 于2019年7月21日周日 下午1:30写道： > Hi Becket, > > Big +1 on this. > > > Regarding the vote of FLIP, preferably at least includes a PMC vote. > Perhaps what Jincheng means is to hold at least one PMC in the 3 binding > votes? i.e, the vote could have 2 binding c

Re: [ANNOUNCE] Kete Young is now part of the Flink PMC

Congratulations Kurt! best forward Jark Wu 于2019年7月23日周二 下午5:49写道： > Congratulations Kurt! Well deserved. > > Cheers, > Jark > > On Tue, 23 Jul 2019 at 17:43, LakeShen wrote: > > > Congratulations Kurt! > > > > Congxian Qiu 于2019年7月23日周二 下午5:37写道： > > > > > Congratulations Kurt! > > > Best,

Custom type serializer inside Flink state

Hi Flink community: Our Flink application sends different types of protobuf messages on-the-wire. Since protobuf cannot be handled by Flink type serializer, we had to register custom Kyro serializer: env.getConfig().*registerTypeWithKryoSerializer*(MyProtoClass1.class, ProtobufSerializer.class);

Re: Custom type serializer inside Flink state

gt; > CC @Tzu-Li (Gordon) Tai<mailto:tzuli...@apache.org> as he might provide > more information about this. > > [1] https://issues.apache.org/jira/browse/FLINK-11333 > > Best > Yun Tang > > > From: Ying Xu > Sent: Thursday, August

[DISCUSS] Support JSON functions in Flink SQL

Hi everybody, I'd like to kick off a discussion on Support JSON functions in Flink SQL. The entire plan is divided into two steps: 1. Implement Support SQL 2016-2017 JSON functions in Flink SQL[1]. 2. Implement non-Support SQL 2016-2017 JSON functions in Flink SQL, such as JSON_TYPE in Mysql, JSO

Re: [DISCUSS] Support JSON functions in Flink SQL

hi Danny Chan ,Thank you very much for your reply, your help can help me further improve this discussion. Best forward Danny Chan 于2019年9月4日周三 下午8:50写道： > Thanks Xu Forward for bring up this topic, I think the JSON functions are > very useful especially for those MySQL users. > > I

Re: [DISCUSS] FLIP-66: Support time attribute in SQL DDL

Thanks Jark for this topic, This will be very useful. Best, ForwardXu Danny Chan 于2019年9月6日周五 上午11:26写道： > Thanks Jark for bring up this topic, this is definitely an import feature > for the SQL, especially the DDL users. > > I would spend some time to review this design doc, really thanks. >

Re: [ANNOUNCE] Kostas Kloudas joins the Flink PMC

Congratulations Kloudas! Best, Forward Dawid Wysakowicz 于2019年9月6日周五 下午10:36写道： > Congratulations Klou! > > Best, > > Dawid > > On 06/09/2019 14:55, Fabian Hueske wrote: > > Hi everyone, > > > > I'm very happy to announce that Kostas Kloudas is joining the Flink PMC. > > Kostas is contributin

Re: [ANNOUNCE] Zili Chen becomes a Flink committer

Congratulations Zili Chen! Best, Forward Till Rohrmann 于2019年9月11日周三 下午5:23写道： > Hi everyone, > > I'm very happy to announce that Zili Chen (some of you might also know him > as Tison Kun) accepted the offer of the Flink PMC to become a committer of > the Flink project. > > Zili Chen has been

Re: [ANNOUNCE] Zili Chen becomes a Flink committer

Congratulations Zili Chen ! ！ Best， Leonard Xu > On 2019年9月12日, at 上午11:02, Yun Tang wrote: > > Congratulations Zili > > Best > Yun Tang > > From: Yun Gao <mailto:yungao...@aliyun.com.invalid>> > Sent: Thursday, September

Re: How stable is FlinkSQL.

Hi Srikanth, Here are some past developer profiles you can view. https://ververica.cn/developers-resources/ Many of them are cases of Flink-SQL. Best, Forward srikanth flink 于2019年9月16日周一 下午9:39写道： > Hi Kurt, > > thanks for quick response. Is the email user@ml? > > Regards > Srikanth > >

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

+1(binding) Best, Leonard > On Apr 21, 2023, at 2:50 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 p

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

; Zhanghao Chen 于2023年4月23日周日 17:33写道： >>>>> >>>>>> Congratulations, Leonard! >>>>>> >>>>>> >>>>>> Best, >>>>>> Zhanghao Chen >>>>>> >&g

Re: [DISCUSS] Planning Flink 2.0

Thanks Xintong and Jark for kicking off the great discussion! The time goes so fast, it is already the 10th anniversary of Flink as an Apache project. Although I haven't gone through the proposal carefully, +1 for the perfect release time and the release managers candidates. Best, Leonard >

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

+1 (binding) - built from source code succeeded - verified signatures - verified hashsums - checked Github release tag - reviewed the web PR Best, Leonard > 2023年4月20日 上午3:29，Martijn Visser 写道： > > +1 (binding) > > - Validated hashes > - Verified signature > - Verified that no binaries ex

Re: [VOTE] Release flink-connector-pulsar, release candidate #1

+1 (binding) - built from source code succeeded - verified signatures - verified hashsums - checked Github release tag - checked release notes - reviewed the web PR and left minor comment Best, Leonard > 2023年4月24日 下午5:13，Danny Cranmer 写道： > > +1 (binding) > > - Release notes look ok > - Ve

Re: [VOTE] Release flink-connector-opensearch, release candidate #1

+1 (binding) - built from source code succeeded - verified signatures - verified hashsums - checked Github release tag - checked release notes - reviewed the web PR Best, Leonard > 2023年5月2日 下午3:14，Khanh Vu 写道： > > +1 (non-binding) > > - Verified sha512 checksum matches file archive. > - V

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

+1 (binding) - built from source code succeeded - verified signatures - verified hashsums - checked Github release tag - checked release notes - reviewed the web PR - found the JDBC docs contains a valid link, reopened FLINK-31759[1] to fix it, not a blocker Best, Leonard [1]https://issues.ap

Re: [VOTE] Release flink-connector-gcp-pubsub v3.0.1, release candidate #1

+1 (binding) - built from source code succeeded - verified signatures - verified hashsums - checked Github release tag - checked release notes - reviewed the web PR Best, Leonard > 2023年4月20日 上午3:17，Martijn Visser 写道： > > +1 (binding) > > - Validated hashes > - Verified signature > - Verif

Re: [VOTE] Release flink-connector-elasticsearch, release candidate #1

+1 (binding) - built from source code succeeded - verified signatures - verified hashsums - checked Github release tag - checked release notes - checked the contents of maven repo - reviewed the web PR Best, Leonard > 2023年4月21日 上午1:07，Ahmed Hamdy 写道： > > + (non-binding) > - Verified signat

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

-1 (binding) as the blocker issue FLINK-31927[1] found - Reviewed the PR [2] and left one comment that the linked issue is incorrect. Best, Leonard [1] https://issues.apache.org/jira/browse/FLINK-31927 [2] https://github.com/apache/flink-connector-cassandra/pull/13 > 2023年5月3日 下午5:26，Etienne

Re: [VOTE] Release flink-shaded 17.0, release candidate #1

+1 (binding) - built from source code succeeded - verified signatures - verified hashsums - checked Github release tag - checked release notes - reviewed the web PR - filed issue FLINK-31994[1] to update the copyright year, not a blocker Best, Leonard [1] https://issues.apache.org/jira/browse/

Re: 您好，退订

Please send email to dev-unsubscr...@flink.apache.org if you want to unsubscribe the mail from dev@flink.apache.org, and you can refer[1][2] for more details. 请发送任意内容的邮件到 dev-unsubscr...@flink.apache.org 地址来取消订阅来自 dev@flink.apache.org 邮件组的邮件，你可以参考[1][2] 管理邮件订阅。 Best, Leonard [1]https://flink.a

[VOTE] Release flink-connector-pulsar 3.0.1, release candidate #1

Hey all, Please review and vote on the release candidate #1 for the version 3.0.1 of the Apache Flink Pulsar Connector 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 inclu

Re: [VOTE] Release flink-connector-cassandra 3.1.0, release candidate #2

+1 (binding) - built from source code succeeded - verified signatures - verified hashsums - checked Github release tag - checked release notes - checked the contents contains jar and pom files in apache repo - reviewed the web PR Best, Leonard > On May 24, 2023, at 4:38 PM, Danny Cranmer wr

Re: [DISCUSS] FLIP-307: Flink connector Redshift

Thanks @Samrat for bringing this discussion. It makes sense to me to introduce AWS Redshift connector for Apache Flink, and I’m glad to help review the design as well as the code review. About the implementation phases, How about prioritizing support for the Datastream Sink API and TableSink AP

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

+1 (binding) - built from source code succeeded - verified signatures - verified hashsums - checked Github release tag, left one minor comment about the release commit - checked release notes - checked the contents contains jar and pom files in apache repo - reviewed the web PR Best, Leonard

Re: [DISCUSS] FLIP-294: Support Customized Job Meta Data Listener

. Best, Leonard > On May 26, 2023, at 4:08 PM, Shammon FY wrote: > > Hi devs, > > We would like to bring up a discussion about FLIP-294: Support Customized > Job Meta Data Listener[1]. We have had several discussions with Jark Wu, > Leonard Xu, Dong Lin, Qingsheng Ren a

Re: [DISCUSS] FLIP-294: Support Customized Job Meta Data Listener

per >> cluster), so this won't introduce a new code path for running per-job / >> per-session user code. Is that correct? >> >> Best, >> D >> >> On Tue, Jun 6, 2023 at 9:17 AM Leonard Xu wrote: >> >>> Thanks Shammon for driving thi

Re: [DISCUSS] FLIP 295: Support persistence of Catalog configuration and asynchronous registration

gt;> If we get a Catalog from CatalogStore, after >>> initializing >>>>> it, >>>>>>>> whether >>>>>>>>>> we >>>>>>>>>>> put it in Map catalogs again? >>>>>>>>>>> >>>>>&g

Re: [DISCUSS] FLIP-308: Support Time Travel In Batch Mode

Hi, Feng Thanks for driving this FLIP, very impressive feature that users want, I’ve some quick questions here. 1.Unification SQL: The snapshot concept exists both in Batch mode and Streaming mode, could we consider a unified proposal? I think users won’t another SQL syntax named Ti

Re: [VOTE] Release flink-connector-pulsar 3.0.1, release candidate #1

gt;> >>>>> + the release now can communicate with Pulsar using OAuth2 auth >> plugin >>>>> + build from source and run unit tests with JDK 17 on macOS M1Max >>>>> >>>>> >>>>> On Wed, May 31, 2023 at 4:24 AM Zili Chen

Re: [VOTE] Release flink-connector-pulsar 3.0.1, release candidate #1

Thanks all ! This vote is now closed, I'll announce the results in a separate thread. Best, Leonard > On Jun 7, 2023, at 3:17 PM, Leonard Xu wrote: > > > +1 (binding) > > - built from source code succeeded > - verified signatures > - verified hashsums &

[RESULT][VOTE] Release flink-connector-pulsar 3.0.1, release candidate #1

I'm happy to announce that we have unanimously approved this release. There are 7 approving votes, 4 of which are binding: * Zili Chen (non-binding) * Neng Lu (non-binding) * Jing Ge (non-binding) * Jark Wu (binding) * Jingsong Li (binding) * Martijn Visser (binding) * Leonard Xu (binding)

[ANNOUNCE] Apache flink-connector-pulsar v3.0.1 released

The Apache Flink community is very happy to announce the release of Apache flink-connector-pulsar v3.0.1. This release is compatible with Flink 1.16.x series. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data stream

Re: [DISCUSS] FLIP-308: Support Time Travel In Batch Mode

nderstand that >>>> "Catalog.getTable(tablePath).on(timeStamp)" may not meet the >>> requirements. >>>> The timestamp is for Catalog's use, and Catalog obtains the >> corresponding >>>> schema based on this time. >>>>

Re: [VOTE] FLIP-295: Support lazy initialization of catalogs and persistence of catalog configurations

Thanks Feng for driving this FLIP forward. +1(binding) Best, Leonard > On Jun 15, 2023, at 1:42 PM, Dong Lin wrote: > > Thanks Feng for the FLIP. > > +1(binding) > > Cheers, > Dong > > On Wed, Jun 14, 2023 at 10:35 AM Feng Jin wrote: > >> Hi everyone >> >> Thanks for all the feedback ab

Re: [ANNOUNCE] Updates to Flink's external connector CI workflows

Thanks Martijn for the great work ! Best, Leonard

Re: [VOTE] FLIP-294: Support Customized Catalog Modification Listener

+1 (binding) Best, Leonard > On Jun 14, 2023, at 11:21 PM, Jing Ge wrote: > > +1 (binding) > > Best Regards, > Jing > > On Wed, Jun 14, 2023 at 4:07 PM Benchao Li wrote: > >> +1 (binding) >> >> Shammon FY 于2023年6月14日周三 19:52写道： >> >>> Hi all: >>> >>> Thanks for all the feedback for F

Re: [VOTE] FLIP-308: Support Time Travel

+1(binding) Best, Leonard > On Jun 19, 2023, at 8:53 PM, Jing Ge wrote: > > +1(binding) > > On Mon, Jun 19, 2023 at 1:57 PM Benchao Li wrote: > >> +1 (binding) >> >> Lincoln Lee 于2023年6月19日周一 19:40写道： >> >>> +1 (binding) >>> >>> Best, >>> Lincoln Lee >>> >>> >>> yuxia 于2023年6月19日周一 19

Re: [VOTE] FLIP-287: Extend Sink#InitContext to expose TypeSerializer, ObjectReuse and JobID

+1(binding) Best, Leonard > On Jun 19, 2023, at 8:12 PM, Martijn Visser wrote: > > +1 (binding) > > On Mon, Jun 19, 2023 at 4:58 AM Yuepeng Pan wrote: > >> +1 (non-binding) >> >> Thanks, >> Roc >> >> >> >> >> >> >> 在 2023-06-19 10:55:05，"Zhu Zhu" 写道： >>> +1 (binding) >>> >>> Thanks,

Re: [DISCUSS] FLIP-307: Flink connector Redshift

>>>>>>>>>>> familiar with their Redshift setup and have specific >>>> expectations >>>>>>> for >>>>>>>>> the >>>>>>>>>>> sink. By making these configurations mandatory, users ca

Re: [DISCUSS] FLIP-309: Enable operators to trigger checkpoints dynamically

Thanks Dong for driving this FLIP forward! Introducing `backlog status` concept for flink job makes sense to me as following reasons: From concept/API design perspective, it’s more general and natural than above proposals as it can be used in HybridSource for bounded records, CDC Source for h

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

+1 (binding) - built from source code succeeded - verified signatures - verified hashsums - checked release notes - checked the contents contains jar and pom files in apache repo - reviewed the web PR Best, Leonard > On Jun 19, 2023, at 6:57 PM, Danny Cranmer wrote: > > Thanks for driving t

Re: Flink Mongodb Sink - Issues

Hi Harish Jiabao has helped troubleshoot the issue[1] and fixed it very efficiently less than 24 hours, Thanks Jiabao! You can built mongodb connector base on latest main branch, or you can wait the next connector release. Best, Leonard [1]https://issues.apache.org/jira/browse/FLINK-32446

Re: [VOTE] FLIP-309: Support using larger checkpointing interval when source is processing backlog

+1 (binding) Best, Leonard > On Jun 29, 2023, at 1:25 PM, Jingsong Li wrote: > > +1 binding > > On Thu, Jun 29, 2023 at 11:03 AM Dong Lin wrote: >> >> Hi all, >> >> We would like to start the vote for FLIP-309: Support using larger >> checkpointing interval when source is processing backlog

Re: [DISCUSS] Deprecate SourceFunction APIs

+1 to deprecate. +1 for David’s points. I’ve one related question, do we have any plan to offer a lighter Source API to decrease the connector development cost? New Source API is good but too heavy for use cases like tests or even some simple connectors. Best, Leonard > On Jun 6, 2022, at 9:

Re: [ANNOUNCE] Apache Flink has won the 2023 SIGMOD Systems Award

Congrats to all ! It will be helpful to promote Apache Flink if we can add a page to our website like others[2]. I’ve created an issue to improve this. Best, Leonard [1] https://issues.apache.org/jira/browse/FLINK-32555 [2] https://spark.apache.org/news/sigmod-system-award.html

Re: [DISCUSS] FLIP-314: Support Customized Job Lineage Listener

Thanks Shammon for driving this FLIP, I have some comments about the updated FLIP. 1. It confuses for me that LineageEdge interface contains multiple sources but one sink, the relation looks like a graph instead of an edge in topology. 2. TableColumnSourceLineageVertex interface is not clea

Re: [VOTE] Release 2.0 must-have work items

Thanks Xintong for driving this great work! But I’ve to give my -1(binding) here： -1 to mark "deprecat SourceFunction/SinkFunction/Sinkv1" item as must to have for release 2.0. I do a lot of connector work in the community, and I have two insights from past experience: 1. Many developers repo

Re: [DISCUSS] FLIP 333 - Redesign Apache Flink website

+1 for the redesigning, the new website looks cool. Best, Leonard > On Jul 11, 2023, at 7:55 AM, Mohan, Deepthi > wrote: > > Hi, > > I’m opening this thread to discuss a proposal to redesign the Apache Flink > website: https://flink.apache.org. The approach and a few initial mockups are >

Re: [VOTE] Release 2.0 must-have work items

PIs - SourceFunction / SinkFunction / SinkV1" with must have item "Remove deprecated APIs SinkV1" . Best, Leonard > > Best, > > Xintong > > > > On Tue, Jul 11, 2023 at 4:26 PM Leonard Xu wrote: > >> Thanks Xintong for driving t

Re: Flink 2.0 connectors, formats, and even user code should also be pluggable.

Hello Zhiqiang, Although it is strange to receive such an email on the dev mailing list, I read your email carefully. The Pluggable mechanism for Connectors, Formats is indeed necessary, and I believe that developers in the community also have this consensus. Regarding the relationship between

Re: [DISCUSS] FLIP-309: Enable operators to trigger checkpoints dynamically

+1 for interval-during-backlog best， leonard > On Jul 14, 2023, at 11:38 PM, Piotr Nowojski wrote: > > Hi All, > > We had a lot of off-line discussions. As a result I would suggest dropping > the idea of introducing an end-to-end-latency concept, until > we can properly implement it, which wi

Re: [VOTE] FLIP-309: Support using larger checkpointing interval when source is processing backlog

Thanks Dong for the continuous work. +1(binding) Best, Leonard > On Jul 18, 2023, at 10:16 PM, Jingsong Li wrote: > > +1 binding > > Thanks Dong for continuous driving. > > Best, > Jingsong > > On Tue, Jul 18, 2023 at 10:04 PM Jark Wu wrote: >> >> +1 (binding) >> >> Best, >> Jark >> >>

Re: [DISCUSS][2.0] FLIP-341: Remove MetricGroup methods accepting an int as a name

+1, there’re methods offer parameter with String which allows users to migrate. Best, Leonard > On Jul 18, 2023, at 9:26 PM, Jing Ge wrote: > > +1 > > On Tue, Jul 18, 2023 at 1:11 PM Chesnay Schepler wrote: > >> Good catch; i've fixed the list. >> >> On 18/07/2023 12:20, Xintong Song wrote:

Re: [DISCUSS] FLIP-346: Deprecate ManagedTable related APIs

Thanks Jane for driving this FLIP. +1, Minor: We can remove related document as well, Keeping a external link to Apache Paimon should be enough. Best, Leonard > On Jul 20, 2023, at 3:07 PM, Martijn Visser wrote: > > +1 > > On Thu, Jul 20, 2023 at 7:53 AM Xintong Song wrote: > >> +1 >>

Re: Kubernetes Operator 1.6.0 release planning

+1 for the release and Gyula as release manager. Best, Leonard > On Jul 20, 2023, at 7:45 PM, Paul Lam wrote: > > Thanks, Gyula. > > +1 (non-binding) > > Best, > Paul Lam > >> 2023年7月20日 19:18，Márton Balassi 写道： >> >> Thanks, Gyula. >> >> +1 (binding) >> >> On Thu, Jul 20, 2023 at 5:01 A

Re: [DISCUSS] FLIP-346: Deprecate ManagedTable related APIs

023 at 4:58 PM Jing Ge wrote: > >> +1 >> >> On Thu, Jul 20, 2023 at 10:37 AM Lincoln Lee >> wrote: >> >>> +1 >>> >>> >>> Best, >>> Lincoln Lee >>> >>> >>> Leonard Xu 于2023年7月20日周四 16:26写道：

Re: [VOTE] Release 2.0 must-have work items

Hi Alexander > I see your concerns regarding the complexity of migration, but we still > have one year to address them. Not only the complexity of migration, but also we lack migration path for now. We have to deprecate SourceFunction/SinkFunction in 1.18 which feature freeze date is 2023/07/2

Re: [VOTE] FLIP-346: Deprecate ManagedTable related APIs

+1 Best, Leonard > On Jul 21, 2023, at 4:02 PM, yuxia wrote: > > +1（binging） > > Best regards, > Yuxia > > - 原始邮件 - > 发件人: "Jane Chan" > 收件人: "dev" > 发送时间: 星期五, 2023年 7 月 21日 下午 3:41:11 > 主题: [VOTE] FLIP-346: Deprecate ManagedTable related APIs > > Hi developers, > > Thanks for a

Re: [VOTE] Release 2.0 must-have work items

> @Leonard > If we follow the agreed-upon and voted path and do not revert [1], all the > formalities get fulfilled Hi Alexander Sorry for making you uncomfortable even though it was discussed on the dev list and under JIRA before reverting this PR. I'm also +1 for the FLIP as your posted.

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

Congratulations, Yong Fang Best, Leonard > On Jul 24, 2023, at 2:01 PM, yuxia wrote: > > Congrats, Shammon! > > Best regards, > Yuxia > > - 原始邮件 - > 发件人: "Benchao Li" > 收件人: "dev" > 抄送: "Shammon FY" > 发送时间: 星期一, 2023年 7 月 24日 下午 1:23:55 > 主题: Re: [ANNOUNCE] New Apache Flink Committ

Re: [DISCUSS] Proposing an LTS Release for the 1.x Line

+1, it’s pretty necessary especially we deprecated so many APIs in 1.18 and plan to remove in 2.0. The 1.19 should be a proper version for LTS Release. Best, Leonard > On Jul 25, 2023, at 3:30 AM, Alexander Fedulov > wrote: > > Hello everyone, > > Recently, there were a lot of discussions

Re: [VOTE] Release 2.0 must-have work items

Best, Leonard [1] https://issues.apache.org/jira/browse/FLINK-28045 > On Jul 21, 2023, at 6:09 PM, Chesnay Schepler wrote: > > On 21/07/2023 11:45, Leonard Xu wrote: >> In this way, the user will see the deprecated API firstly but they can not >> find a candidate if we can n

Re: [VOTE] Release 2.0 must-have work items - Round 2

Thanks @xingtong for driving the work. +1(binding) Best, Leonard > On Jul 26, 2023, at 3:18 PM, Konstantin Knauf > wrote: > > Hi Xingtong, > > yes, I am fine with the conclusion for SourceFunction. I chatted with > Leonard a bit last night. Let's continue this vote. > > Thanks for the clari

Re: [ANNOUNCE] Flink 1.18 feature freeze

Thank all Release Managers for driving the 1.18 release work! > - Deprecation works for 2.0 > > As discussed in another thread [3], we will not give extra extensions to > deprecation works considering the overhead and potential side effects to > the timeline of 1.18. We can accept tiny changes th

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

Congratulations, Hong! Best, Leonard > On Aug 3, 2023, at 8:45 PM, Jiabao Sun > wrote: > > Congratulations, Hong Teoh! > > Best, > Jiabao Sun > >> 2023年8月3日 下午7:32，Danny Cranmer 写道： >> >> On behalf of the PMC, I'm very happy to announce Hong Teoh as a new Flink >> Committer. >> >> Hong h

Re: [DISCUSS] Release flink-connector-mongodb 1.0.2

Thanks Jiabao and Danny for driving the work! I’m available if you nee help when prepare the release. Best, Leonard > On Aug 3, 2023, at 9:15 PM, Jiabao Sun > wrote: > > Hi, > > We make some commits from the v1.0.1 release[1], especially one bug fix for > the MongoWriter should regularly che

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

Congratulations, Matthias. Well deserved ^_^ Best, Leonard > On Aug 4, 2023, at 11:18 AM, Xintong Song wrote: > > Hi everyone, > > On behalf of the PMC, I'm very happy to announce that Matthias Pohl has > joined the Flink PMC! > > Matthias has been consistently contributing to the project

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

Congratulations Weihua! Best, Leonard > On Aug 4, 2023, at 11:18 AM, Xintong Song wrote: > > Hi everyone, > > On behalf of the PMC, I'm very happy to announce Weihua Hu as a new Flink > Committer! > > Weihua has been consistently contributing to the project since May 2022. He > mainly works

Re: [VOTE] Release flink-connector-mongodb v1.0.2, release candidate 1

Thanks Danny and Jiabao for driving the work! +1 (binding) - built from source code succeeded - verified signatures - verified hashsums - checked release notes - reviewed the web PR Best, Leonard > On Aug 6, 2023, at 6:58 PM, Ahmed Hamdy wrote: > > Thanks Danny > + 1 (non-binding) > > *

Re: [DISCUSS] FLIP-307: Flink connector Redshift

Thanks Samrat and Danny for driving this FLIP. >> an effective approach is to utilize the latest version of >> flink-connector-jdbc > as a Maven dependency > > When we have stable source/sink APIs and the connector versions are > decoupled from Flink this makes sense. But right now this would m

Re: [DISCUSS] FLIP-328: Allow source operators to determine isProcessingBacklog based on watermark lag

Thanks Xuannan for driving this FLIP ! The proposal generally looks good to me, but I still left some comments: > One more question about the FLIP is that the FLIP says "Note that this > config does not support switching source's isProcessingBacklog from false to > true > for now.” Does that me

Re: [VOTE] Release flink-connector-hbase v3.0.0, release candidate 2

+1 (binding) - built from source code succeeded - verified signatures - verified hashsums - checked release notes - reviewed the web PR Best, Leonard > On Sep 11, 2023, at 7:01 PM, Danny Cranmer wrote: > > Hey Martijn, thanks for picking this up. > > +1 (binding) > > - Release notes look

Re: [DISCUSS] FLIP-314: Support Customized Job Lineage Listener

Thanks Shammon for the informations, the comment makes the lifecycle clearer. +1 Best, Leonard > On Sep 18, 2023, at 7:54 PM, Shammon FY wrote: > > Hi devs, > > After discussing with @Qingsheng, I fixed a minor issue of the lineage > lifecycle in `StreamExecutionEnvironment`. I have added

Re: [VOTE] FLIP-307: Flink Connector Redshift

+1 (binding) Best, Leonard > On Sep 18, 2023, at 11:53 PM, Ahmed Hamdy wrote: > > +1 (non-binding) > Best Regards > Ahmed Hamdy > > > On Mon, 18 Sept 2023 at 16:52, Jing Ge wrote: > >> +1(binding). Thanks! >> >> Best regards, >> Jing >> >> On Mon, Sep 18, 2023 at 5:26 PM Danny Cranmer >

Re: [VOTE] FLIP-312: Prometheus Sink Connector

Thanks Lorenzo for driving this. +1(binding) Best, Leonard > On Sep 21, 2023, at 11:47 AM, Yun Tang wrote: > > +1 (binding) > > Thanks for driving this, Lorenzo. > > Best > Yun Tang > > From: Hong > Sent: Thursday, September 21, 2023 1:22 > To: dev@flink.apa

Re: [Re-DISCUSS] FLIP-202: Introduce ClickHouse Connector

I share same concern with Matijn, how about invite the author of unofficial flink-clickhouse-connector itinycheng to co-author the FLIP? @ConradJam And then user would like to use the new official connector from users’ perspective, the maintaining work of unofficial CK connector and the new CK

Re: [VOTE] FLIP-314: Support Customized Job Lineage Listener

+1(binding) Best, Leonard > On Sep 26, 2023, at 9:59 AM, Feng Jin wrote: > > +1(no-binding) > > > thanks for driving this proposal > > > Best, > Feng > > On Mon, Sep 25, 2023 at 11:19 PM Jing Ge wrote: > >> +1(binding) Thanks! >> >> Best Regards, >> Jing >> >> On Sun, Sep 24, 2023 at

Re: [VOTE] FLIP-367: Support Setting Parallelism for Table/SQL Sources

+1（binding） Best, Leonard > On Oct 9, 2023, at 9:45 PM, Jing Ge wrote: > > +1(binding) > > Best Regards, > Jing > > On Mon, Oct 9, 2023 at 10:40 AM Ahmed Hamdy wrote: > >> +1 (non-binding) >> Best Regards >> Ahmed Hamdy >> >> >> On Mon, 9 Oct 2023 at 09:38, xiangyu feng wrote: >> >>> +1

dev@flink.apache.org

Thanks Joao for driving this work. +1 (binding) Best, Leonard > On Oct 12, 2023, at 7:09 PM, Sergey Nuyanzin wrote: > > +1 (binding)

Re: [ANNOUNCE] New Apache Flink Committer - Jane Chan

> Congrats! I noticed Jane has been around for a while; well-deserved. > > Best, > tison. +1 Best, Leonard > > > Jark Wu 于2023年10月16日周一 09:58写道： > >> Hi, everyone >> >> On behalf of the PMC, I'm very happy to announce Jane Chan as a new Flink >> Committer. >> >> Jane started code con

Re: [ANNOUNCE] New Apache Flink Committer - Ron Liu

Congratulations, Ron! Best, Leonard > 2023年10月16日 下午2:10，Zakelly Lan 写道： > > Congratulations, Ron! > > Best, > Zakelly > > On Mon, Oct 16, 2023 at 12:04 PM Weihua Hu wrote: >> >> Congrats, Ron! >> >> Best, >> Weihua >> >> >> On Mon, Oct 16, 2023 at 11:50 AM Yangze Guo wrote: >> >>> Con

Re: [VOTE] FLIP-371: Provide initialization context for Committer creation in TwoPhaseCommittingSink

Thanks Peter for driving this work. +1(binding) Best, Leonard > 2023年10月12日 下午10:58，Márton Balassi 写道： > > +1 (binding) > > Marton > > On Wed, Oct 11, 2023 at 8:20 PM Gyula Fóra wrote: > >> Thanks , Peter. >> >> +1 >> >> Gyula >> >> On Wed, 11 Oct 2023 at 14:47, Péter Váry >> wrote: >

Re: [DISCUSS] FLIP-371: SinkV2 Committer imporvements

Thanks Peter for driving this FLIP. One minor comment: The code for API SinkCommitterMetricGroup should be updated as description, SinkWriterMetricGroup looks like a typo. Best, Leonard > 2023年10月10日 下午1:21，Péter Váry 写道： > > Hi everyone, > > It seems we have no more comments. So I would li

Re: [VOTE] FLIP-371: Provide initialization context for Committer creation in TwoPhaseCommittingSink

No more comments, give my +1(binding) Best, Leonard > 2023年10月16日 下午6:20，Péter Váry 写道： > > Any more comments? > > Leonard Xu ezt írta (időpont: 2023. okt. 16., H, 8:22): > >> Thanks Peter for driving this work. >> >> >> +1(binding) >>

Re: [DISCUSS] Remove legacy Paimon (TableStore) doc link from Flink web navigation

+1 > 2023年10月17日 下午4:50，Martijn Visser 写道： > > +1 > > On Tue, Oct 17, 2023 at 10:34 AM Jingsong Li wrote: >> >> Hi marton, >> >> Thanks for driving. +1 >> >> There is a PR to remove legacy Paimon >> https://github.com/apache/flink-web/pull/665 , but it hasn't been >> updated for a long tim

Re: [ANNOUNCE] The Flink Speed Center and benchmark daily run are back online

Thanks Zakelly for the great work. Best, Leonard > 2023年10月19日 下午7:39，Jing Ge 写道： > > Hi Zakelly, > > Thank you for your effort! Really appreciate it! > > Best regards, > Jing > > On Thu, Oct 19, 2023 at 12:02 PM Yun Tang wrote: > >> Thanks for Zakelly's great work! >> >> >> Best >> Yun

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

+1 (binding) - verified signatures - verified hashsums - built from source code succeeded - checked all dependency artifacts are 1.18 - started SQL Client, used MySQL CDC connector to read changelog from database , the result is expected - reviewed the web PR, left minor comments - reviewed the

Re: FLIP-233

+1 to reopen the FLIP, the FLIP has been stalled for more than a year due to the author's time slot. Glad to see the developers from IBM would like to take over the FLIP, we can continue the discussion in FLIP-233 discussion thread [1] Best, Leonard [1] https://lists.apache.org/thread/cd60ln4

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

Thanks @Jiabao for kicking off this discussion. Could you add a section to explain the difference between proposed connector level config `scan.filter-push-down.enabled` and existing query level config `table.optimizer.source.predicate-pushdown-enabled` ? Best, Leonard > 2023年10月24日 下午4:18，Jia

Re: [ANNOUNCE] Apache Flink 1.18.0 released

Congratulations, Well done! Best, Leonard On Fri, Oct 27, 2023 at 12:23 AM Lincoln Lee wrote: > Thanks for the great work! Congrats all! > > Best, > Lincoln Lee > > > Jing Ge 于2023年10月27日周五 00:16写道： > > > The Apache Flink community is very happy to announce the release of > Apache > > Flink 1.

  1   2   3   4   5   6   7   8   9   10   >