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

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

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

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

[jira] [Created] (FLINK-32555) Add a page to show SIGMOD System Awards for Apache Flink

Leonard Xu created FLINK-32555: -- Summary: Add a page to show SIGMOD System Awards for Apache Flink Key: FLINK-32555 URL: https://issues.apache.org/jira/browse/FLINK-32555 Project: Flink Issue

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

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

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] 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

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

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 can >>> have >>>>>>

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) >>> >>>

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日周一

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

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

Thanks Martijn for the great work ! Best, Leonard

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

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

corresponding >>>> schema based on this time. >>>> >>>> >>>> @liu @Regards >>>> >>>> I am very sorry for the unclear description in the document. I have >>> updated >>>> relevant descriptions regar

[jira] [Created] (FLINK-32289) The metadata column type is incorrect in Kafka table connector example

Leonard Xu created FLINK-32289: -- Summary: The metadata column type is incorrect in Kafka table connector example Key: FLINK-32289 URL: https://issues.apache.org/jira/browse/FLINK-32289 Project: Flink

[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

[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

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 > -

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 C

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

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

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

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

t; 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 this FLIP forward,

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 R

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-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

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

[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

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

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]

[jira] [Created] (FLINK-31994) Update copyright in NOTICE files of flink-shaded

Leonard Xu created FLINK-31994: -- Summary: Update copyright in NOTICE files of flink-shaded Key: FLINK-31994 URL: https://issues.apache.org/jira/browse/FLINK-31994 Project: Flink Issue Type

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日

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

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 > -

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

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. > -

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 > -

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

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: [ANNOUNCE] New Apache Flink PMC Member - Leonard Xu

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

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

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

+1 (binding) - verified signatures - verified hashsums - checked Github release tag - built from source code succeeded - reviewed the web PR Best, Leonard > On Apr 20, 2023, at 2:41 AM, Martijn Visser wrote: > > +1 (binding) > > - Validated hashes > - Verified signature > - Verified that

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

n. If partitions still >>> not >>>> exist, it should be specified in the post-startup OffsetsInitializers >>>> (default EARLIEST). >>>> >>>> Best >>>> Hongshun >>>> >>>> >>>> On Thu, Mar 30, 2023

Re: [DISCUSS] FLIP-304: Pluggable failure handling for Apache Flink

gt;>>> definition need to allow them to be asynchronous to >>>>> unblock the >>>>>>>>> main >>>>>>>>>>>>> thread >>>>>>>>>>>>>> for handling other RPCs. Exposing ioExecutor via the >>>>> context >>>>>

Re: [VOTE] FLIP-292: Enhance COMPILED PLAN to support operator-level state TTL configuration

+1 (binding) Best, Leonard

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

Thanks Hongshun and Shammon for driving the FLIP! > *2. Clarification on "future-time" TIMESTAMP OffsetsInitializer* > *3. Clarification on coupling SPECIFIC-OFFSET startup with SPECIFIC-OFFSET > post-startup* Grodan raised a good point about the future TIMESTAMP and SPECIFIC-OFFSET, the

Re: [DISCUSS] Planning Flink 1.18

Thanks Konstantin and Qingsheng for kicking off and pushing forward the discussion. Thanks Qingsheng, Jing, Konstantin, Sergey, Yun for volunteering to release manager candidates, 4 release manager from different timezones make sense to me, it brings better coordination for globalization

Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating)

Congratulations! Best, Leonard > On Mar 27, 2023, at 5:23 PM, Yu Li wrote: > > Dear Flinkers, > > As you may have noticed, we are pleased to announce that Flink Table Store > has joined the Apache Incubator as a separate project called Apache > Paimon(incubating) [1] [2] [3]. The new

Re: [DISCUSS] FLIP-292: Support configuring state TTL at operator level for Table API & SQL programs

Thanks Jane for the proposal. TTL of state is an execution phase configuration, serialized json graph file is the graph for execution phase, supporting the operator level state TTL in the execution json file makes sense to me. >From the user's perspective, I have two concerns: 1. By modifying

Re: [DISCUSS] Use 1.15.4 as the final patch version of Flink 1.15 and drop 1.15 support

+1 as 1.17.0 is available. Best, Leonard > On Mar 24, 2023, at 5:50 PM, Jing Ge wrote: > > Thanks Qingsheng for driving this. +1 since there are no changes after 1.15.4 > > Best regards, > JIng > > On Fri, Mar 24, 2023 at 10:34 AM Qingsheng Ren > wrote: > Hi devs, >

[ANNOUNCE] Apache Flink 1.17.0 released

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

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

Hi, Yu Chen > The test results show that Flink 1.17 has a significant performance > degradation compared to Flink 1.13 (About 8.49%), shall we need to identify > the reason for the performance degradation before Flink 1.17 is released? Thanks for the verification, I wonder why you compared to

[jira] [Created] (FLINK-31531) Test HiveCatalogHiveMetadataTest.testCreateTableWithConstraint failed on azure

Leonard Xu created FLINK-31531: -- Summary: Test HiveCatalogHiveMetadataTest.testCreateTableWithConstraint failed on azure Key: FLINK-31531 URL: https://issues.apache.org/jira/browse/FLINK-31531 Project

Re: [VOTE] FLIP-296: Extend watermark-related features for SQL

+1(binding) minor: The first SQL piece of the FLIP is incorrect as the column name current_time is a system built-in function. Best, Leonard > On Mar 21, 2023, at 9:38 AM, yuxia wrote: > > +1 (binding_ > Thanks Kui for driving it. > > Best regards, > Yuxia > > - 原始邮件 - > 发件人:

Re: [DISCUSS] FLIP-304: Pluggable failure handling for Apache Flink

Hi，Panagiotis Thank you for kicking off this discussion. Overall, the proposed feature of this FLIP makes sense to me. We have also discussed similar requirements with our users and developers, and I believe it will help many users. In terms of FLIP content, I have some thoughts: (1) For the

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

> + 1 (non-binding) > > Best, > Jiaba Hi, Jiabao Thanks for help to verify the release candidate. But we need to do the verification firstly and then post the verified items when in a release candidate vote thread. The community does not require verification of all items in the document

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

Thanks Jing for the validation, I’ve created FLINK-31519[1] to fix the outdated doc, Sure that it’s a minor doc issue and won’t block the release. Best, Leonard [1]https://issues.apache.org/jira/browse/FLINK-31519 > On Mar 20, 2023, at 7:45 AM, Jing Ge wrote: > > Hi Qingsheng, > > While

[jira] [Created] (FLINK-31519) The watermark alignment docs is outdated after FLIP-217 finished

Leonard Xu created FLINK-31519: -- Summary: The watermark alignment docs is outdated after FLIP-217 finished Key: FLINK-31519 URL: https://issues.apache.org/jira/browse/FLINK-31519 Project: Flink

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

Thanks everyone for validating the RC2! As the new blocker issue FLINK-31485[1] we found , the RC2 of 1.17.0 is officially canceled. We'll build a new RC once FLINK-31485 is fixed. Hi, Ran Tao As Martijn’s explanation, FLINK-31319[2] is not a blocker for 1.17. But I’ve reviewed you patch and

[jira] [Created] (FLINK-31484) flink-web compile failed due to local node tar corrupted

Leonard Xu created FLINK-31484: -- Summary: flink-web compile failed due to local node tar corrupted Key: FLINK-31484 URL: https://issues.apache.org/jira/browse/FLINK-31484 Project: Flink Issue

[jira] [Created] (FLINK-31477) NestedLoopJoinTest.testLeftOuterJoinWithFilter failed on azure

Leonard Xu created FLINK-31477: -- Summary: NestedLoopJoinTest.testLeftOuterJoinWithFilter failed on azure Key: FLINK-31477 URL: https://issues.apache.org/jira/browse/FLINK-31477 Project: Flink

Re: [DISCUSS] Enabling dynamic partition discovery by default in Kafka source

Thanks Hongshun for picking up the ticket and analyzing the detail deeply. As you have discussed with Qingsheng offline, I think we can update the content to FLIP-288[1] and then start the FLIP discussion. Best, Leonard [1]

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

Thanks shammon for driving this FLIP. +1 (binding) Best, Leonard On Wed, Mar 15, 2023 at 1:36 PM weijie guo wrote: > +1 (binding) > > Best regards, > > Weijie > > > Jacky Lau 于2023年3月15日周三 13:30写道： > > > +1 (non-binding) > > it will make integrate with other tools convenient, like

Re: [DISCUSS] Release of MongoDB Connector v1.0.0

+1 to prepare the initial release. Thanks Danny and Jiabao for driving this great work, it's a pretty nice addition to the Flink ecosystem. Best, Leonard On Wed, Mar 15, 2023 at 10:44 AM Jiabao Sun wrote: > Hi Danny, > > > +1 non-binding. Looking forward to the init release of this connector!

Re: [ANNOUNCE] Release 1.17.0, release candidate #1

> > The RC works on this tested scope. I'll test again on RC2. Cool, thanks for your validation，Etienne! We'll prepare the RC2 ASAP. Best, Leonard

Re: [ANNOUNCE] Release 1.17.0, release candidate #1

> > By the way, it seems the apache/flink-benchmarks repo did not checkout a > branch target for flink-1.17 [1] ? > Thanks Yun for reporting this, I'll check apache/flink-benchmarks repo. Best, Leonard

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

Congrats Yuxia, impressive work on hive，well deserved! Best, Leonard On Mon, Mar 13, 2023 at 3:49 PM Martijn Visser wrote: > Congrats Yuxia, well deserved! > > On Mon, Mar 13, 2023 at 5:29 AM Jane Chan wrote: > > > Congratulations, Yuxia! > > > > Best, > > Jane > > > > On Mon, Mar 13, 2023 at

[SUMMARY] Flink 1.17 Release Sync 3/7/2023

Hi devs and users, I'd like to share some highlights from Flink 1.17 release sync on 3/7/2023. 1.17 Blockers: - Currently, there is one blocker issue (FLINK-31351[1]) that needs to be resolved before we can create a votable RC1. Our contributors are working hard to fix it as soon as

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

Congratulations, Rui! Best, Leonard > On Feb 21, 2023, at 9:50 AM, Matt Wang wrote: > > Congrats Rui > > > -- > > Best, > Matt Wang > > > Replied Message > | From | yuxia | > | Date | 02/21/2023 09:22 | > | To | dev | > | Subject | Re: [ANNOUNCE] New Apache Flink Committer - Rui

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

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: > >> Congrats Anton! >> >> Best regards, >> Yuxia >> >> - 原始邮件 - >> 发件人: "Matthias Pohl" >>

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

Congratulations, Dong! Best, Leonard > On Feb 16, 2023, at 3:03 PM, Dian Fu wrote: > > Congratulations Dong! > > Regards, > Dian > > On Thu, Feb 16, 2023 at 2:41 PM Junrui Lee wrote: > >> Congratulations, Dong! >> >> Best, >> Junrui >> >> Guowei Ma 于2023年2月16日周四 14:21写道： >> >>> Hi,

Re: [DISCUSS] Release Flink 1.15.4

+1 to release 1.15.4 and Danny as release manager. > On Feb 16, 2023, at 11:31 AM, Rui Fan <1996fan...@gmail.com> wrote: > > +1 > > On Thu, Feb 16, 2023 at 6:51 AM Jing Ge wrote: > >> +1 >> >> On Wed, Feb 15, 2023 at 4:03 PM Konstantin Knauf >> wrote: >> >>> +1 >>> >>> Am Mi., 15. Feb.

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

Congratulations!! Jing Best, Leonard > On Feb 14, 2023, at 4:33 PM, Hang Ruan wrote: > > Congratulations Jing! > > Shammon FY 于2023年2月14日周二 16:04写道： > >> Congratulations Jing! >> >> Best, >> Shammon >> >> On Tue, Feb 14, 2023 at 4:00 PM weijie guo >> wrote: >> >>> Congratulations Jing!

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

Congratulations! Weijie Best, Leonard

[jira] [Created] (FLINK-30964) flink-mirror repo sync release branches failed

Leonard Xu created FLINK-30964: -- Summary: flink-mirror repo sync release branches failed Key: FLINK-30964 URL: https://issues.apache.org/jira/browse/FLINK-30964 Project: Flink Issue Type: Bug

Re: Need help how to use Table API to join two Kafka streams

> The result here is the representation of the statement execution result, NOT > the query output. > You can define a print connector table[1] as your sink table, and insert into > the query output to the sink table to achieve your goal. Correction: you can also iterate the output result

Re: Need help how to use Table API to join two Kafka streams

> 1) *First*: In *payment_msg_proccessing.py > * > code, > I want to run a simple query on Kafka stream (payment_msg table) without > insertion data into the sink table (es_sink here) and do

Re: [ANNOUNCE] release-1.17 branch cut

Hi, Krzysztof > Could someone set FIX version to 1.17 and 1.16.2 on those tickets: [1] [2] > please? Done，thanks for the contribution. And I’ll find contributor to review the later bugfix PR. Best, Leonard

[ANNOUNCE] release-1.17 branch cut

Hi devs, The release-1.17 branch has been forked out from the master branch, with commit ID 4bc6d6dac29b1d7d89850a512b8283858824ae21. The version on the master branch has been upgraded to 1.18-SNAPSHOT. From now on, for PRs that should be presented in 1.17.0, please make sure: Merge the PR

Re: [VOTE] FLIP-208: Add RecordEvaluator to dynamically stop source based on de-serialized records

> Since this change is relatively minor and looks good to me, I will re-use > this voting thread to confirm this change is OK. > > Qingsheng and Leonard: can you help check whether this public interface > change looks good to you? > Thanks Dong and Hang for driving this. The change looks

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

+1 Best, Leonard > On Feb 3, 2023, at 9:49 AM, Dong Lin wrote: > > +1 > > On Thu, Feb 2, 2023 at 9:31 PM Hang Ruan wrote: > >> Hi all, >> >> Thanks for all the help about this FLIP. Now let's start the vote again. >> Based on the discussion[1], we have come to a consensus, so I would like

Re: [DISCUSS] Delete useless branches from Flink repository

nfluence/display/FLINK/Flink+Release+Management > <https://cwiki.apache.org/confluence/display/FLINK/Flink+Release+Management> > [2] https://github.com/apache/flink/tree/blink > <https://github.com/apache/flink/tree/blink> > > On Tue, Nov 1, 2022 at 11:26 AM Leonard Xu &

Re: [ANNOUNCE] FRocksDB 6.20.3-ververica-2.0 released

Thanks Yanfei for driving the release ! ! Best, Leonard > On Jan 31, 2023, at 3:43 PM, Yun Tang wrote: > > Thanks Yuanfei for driving the frocksdb release! > > Best > Yun Tang > From: Yuan Mei > Sent: Tuesday, January 31, 2023 15:09 > To: Jing Ge > Cc: Yanfei Lei ; dev@flink.apache.org >

Re: [DISCUSS] Enabling dynamic partition discovery by default in Kafka source

Thanks Qingsheng for driving this, enable the dynamic partition discovery would be very useful for kafka topic scale partitions scenarios. +1 for the change. CC: Becket Best, Leonard > On Jan 13, 2023, at 3:15 PM, Jark Wu wrote: > > +1 for the change. I think this is beneficial for

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

Congratulations, Lincoln! Impressive work in streaming semantics, well deserved! Best, Leonard > On Jan 10, 2023, at 11:52 AM, Jark Wu wrote: > > Hi everyone, > > On behalf of the PMC, I'm very happy to announce Lincoln Lee as a new Flink > committer. > > Lincoln Lee has been a long-term

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

Thanks for driving this FLIP, Hang! +1 (binding) Best, Leonard > On Jan 5, 2023, at 3:08 AM, Martijn Visser wrote: > > Hi Hang, > > I haven't had time to read the FLIP yet since this is still a holiday > period in Europe. I would like to read it in the next few days. Can you > keep the vote

Re: [DISCUSS] Extending the feature freezing date of Flink 1.17

Thanks Qingsheng for the proposal, the pandemic has really impacted development schedules. Jan 31st makes sense to me. Best, Leonard

Re: [VOTE] FLIP-208: Add RecordEvaluator to dynamically stop source based on de-serialized records

+1 (binding) Best, Leonard > On Dec 26, 2022, at 4:22 PM, Qingsheng Ren wrote: > > +1 (binding) > > Best, > Qingsheng > Ververica (Alibaba) > > On Wed, Dec 21, 2022 at 3:13 PM Dong Lin wrote: > >> Hi all, >> >> We would like to start the vote for FLIP-208: Add RecordEvaluator to >>

[SUMMARY] Flink 1.17 Release Sync 12/13/2022

Hi devs and users, I’d like to share the highlights about the 1.17 release sync on 12/13/2022. - Release tracking page: - 1.17 development is moving forward [1], we have 5 weeks remaining - @committers Please continuously update the the progress in the 1.17 page - Externalized

[jira] [Created] (FLINK-30374) DefaultExecutionGraphCacheTest fails with 239 exit code

Leonard Xu created FLINK-30374: -- Summary: DefaultExecutionGraphCacheTest fails with 239 exit code Key: FLINK-30374 URL: https://issues.apache.org/jira/browse/FLINK-30374 Project: Flink Issue

Re: [ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang

Congratulations，Godfrey and Xingbo! Best, Leonard > On Nov 23, 2022, at 12:32 PM, Geng Biao wrote: > > Congrats，Godfrey and Xingbo! > Best,

[jira] [Created] (FLINK-30136) ElasticsearchSinkITCase.testElasticsearchSink failed on azure due to ES service unavailable

Leonard Xu created FLINK-30136: -- Summary: ElasticsearchSinkITCase.testElasticsearchSink failed on azure due to ES service unavailable Key: FLINK-30136 URL: https://issues.apache.org/jira/browse/FLINK-30136

[jira] [Created] (FLINK-30135) RMQSourceITCase failed on azure with exit code 143

Leonard Xu created FLINK-30135: -- Summary: RMQSourceITCase failed on azure with exit code 143 Key: FLINK-30135 URL: https://issues.apache.org/jira/browse/FLINK-30135 Project: Flink Issue Type

[jira] [Created] (FLINK-30132) Test LocalRecoveryITCase#testRecoverLocallyFromProcessCrashWithWorkingDirectory failed on azure due to File not exists

Leonard Xu created FLINK-30132: -- Summary: Test LocalRecoveryITCase#testRecoverLocallyFromProcessCrashWithWorkingDirectory failed on azure due to File not exists Key: FLINK-30132 URL: https://issues.apache.org/jira

Re: [ANNOUNCE] New Apache Flink Committer - Matyas Orhidi

Congratulations Matyas, well deserved! Best, Leonard > On Nov 22, 2022, at 9:38 AM, Dian Fu wrote: > > Congrats Matyas! > > On Tue, Nov 22, 2022 at 9:00 AM Tony Wei wrote: > >> Congrats Matyas! >> >> Thomas Weise 於 2022年11月22日 週二 上午8:56寫道： >> >>> Congrats Matyas! >>> >>> >>> On Mon,

[jira] [Created] (FLINK-30108) flink-core module tests exited with code 143

Leonard Xu created FLINK-30108: -- Summary: flink-core module tests exited with code 143 Key: FLINK-30108 URL: https://issues.apache.org/jira/browse/FLINK-30108 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-30107) ChangelogRecoveryITCase#testMaterialization

Leonard Xu created FLINK-30107: -- Summary: ChangelogRecoveryITCase#testMaterialization Key: FLINK-30107 URL: https://issues.apache.org/jira/browse/FLINK-30107 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-30106) Build python wheels on macs failed due to install for crcmod error

Leonard Xu created FLINK-30106: -- Summary: Build python wheels on macs failed due to install for crcmod error Key: FLINK-30106 URL: https://issues.apache.org/jira/browse/FLINK-30106 Project: Flink

<    1   2   3   4   5   6   7   >