Re: Re: Re: [DISCUSS ] Make state.backend.incremental as true by default

The suggestion of Zakelly (Using noDefaultValue to make different StateBackend have its own default value) makes sense to me. I haven't gotten a better idea about it. Maybe @ro...@apache.org who is the owner of incremental checkpoint support of HashMapStateBackend could share more ideas about it.

[jira] [Created] (FLINK-28256) Move the write and prepareCommit logic of AbstractTableWrite to FileStoreWrite

Jingsong Lee created FLINK-28256: Summary: Move the write and prepareCommit logic of AbstractTableWrite to FileStoreWrite Key: FLINK-28256 URL: https://issues.apache.org/jira/browse/FLINK-28256

[jira] [Created] (FLINK-28255) Add extraFiles to DataFileMeta

Jingsong Lee created FLINK-28255: Summary: Add extraFiles to DataFileMeta Key: FLINK-28255 URL: https://issues.apache.org/jira/browse/FLINK-28255 Project: Flink Issue Type: New Feature

Re: [ANNOUNCE] Apache Flink 1.14.5 released

Thanks Xingbo for driving this release! Best, Qingsheng > On Jun 22, 2022, at 11:50, Xingbo Huang wrote: > > The Apache Flink community is very happy to announce the release of Apache > Flink 1.14.5, which is the fourth bugfix release for the Apache Flink 1.14 > series. > > Apache Flink®

Re: [DISCUSS] Contribution of Multi Cluster Kafka Source

Hi Mason, It sounds like an exciting enhancement to the Kafka source and will benefit a lot of users I believe. Would you prefer to reuse the existing flink-connector-kafka module or create a new one for the new multi-cluster feature? Personally I prefer the former one because users won’t

[jira] [Created] (FLINK-28254) Add benchmark of vectorAssembler and minMaxScaler

weibo zhao created FLINK-28254: -- Summary: Add benchmark of vectorAssembler and minMaxScaler Key: FLINK-28254 URL: https://issues.apache.org/jira/browse/FLINK-28254 Project: Flink Issue Type:

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.0.1, release candidate #1

+1 (binding) Successfully verified the following: - Verify that the checksums and GPG files - Verify that the source distributions do not contain any binaries - Build binary and image from release source - Verify the NOTICE and licenses in source release and the docker image - Verify the helm

[jira] [Created] (FLINK-28253) LocalDateTime is not supported in PyFlink

Dian Fu created FLINK-28253: --- Summary: LocalDateTime is not supported in PyFlink Key: FLINK-28253 URL: https://issues.apache.org/jira/browse/FLINK-28253 Project: Flink Issue Type: Bug

Re: [DISCUSS] Releasing Flink ML 2.1.0

Thank you all for the vote and the comments! Based on the response received in this thread, we will go ahead and release Flink ML 2.1.0 RC1 today. Cheers, Zhipeng Jing Ge 于2022年6月25日周六 06:30写道： > +1 > > Looking forward to the new release! Thanks! > > Best regards, > Jing > > > On Fri, Jun 24,

来自杨柳的邮件

退订

[jira] [Created] (FLINK-28252) Potential Refactoring

Alvin Tan Jian Jia created FLINK-28252: -- Summary: Potential Refactoring Key: FLINK-28252 URL: https://issues.apache.org/jira/browse/FLINK-28252 Project: Flink Issue Type: Improvement

Re:Re: Re: [ANNOUNCE] New Apache Flink Committers: Qingsheng Ren, Shengkai Fang

Congratulations, Shengkai and Qingsheng! Best Regards, Yuan At 2022-06-24 16:45:25,"godfrey he" , said: >Congrats, Shengkai and Qingsheng! > >Best, >Godfrey > >Yu Li 于2022年6月22日周三 23:55写道： >> >> Congrats and welcome, Qingsheng and Shengkai! >> >> Best Regards, >> Yu >> >> >> On Wed, 22 Jun