Re: Re: [VOTE] Accept Flink CDC into Apache Flink

+1 (binding) Best, Xingbo Dian Fu 于2024年1月10日周三 11:35写道： > +1 (binding) > > Regards, > Dian > > On Wed, Jan 10, 2024 at 5:09 AM Sharath wrote: > > > > +1 (non-binding) > > > > Best, > > Sharath > > > > On Tue, Jan 9, 2024 at 1:02 PM Venkata Sanath Muppalla < > sanath...@gmail.com> > > wrote:

Re: [DISCUSS] Externalized Python Connector Release/Dependency Process

Hi Danny, +1 Thanks a lot for investigating this. Let me share the current code management and release situation of pyflink here. I hope it will be helpful to you. Since Flink 1.13, release managers need to release two python packages to pypi, apache-flink[1] and apache-flink-libraries[2].

Re: [DISCUSS] Drop python 3.7 support in 1.19

ready a PR which is under development: > https://github.com/apache/flink/pull/23359 > This fills all the mentioned gaps: local test/development/test execution on > ARM CPUs + the previously mentioned 3+ years not actively supported python > eliminated. > > Hope this helps. > &g

Re: [DISCUSS] Drop python 3.7 support in 1.19

. >> Making this change can increase the adoption instantly if we enable new >> platforms. >> >> Cheers, >> Gyula >> >> On Wed, Sep 6, 2023 at 4:46 AM Xingbo Huang wrote: >> >> > Hi Gabor, >> > >> > Thanks for bringing th

Re: [DISCUSS] Drop python 3.7 support in 1.19

Hi Gabor, Thanks for bringing this up. In my opinion, it is a bit aggressive to directly drop Python 3.7 in 1.19. Python 3.7 is still used a lot[1], and as far as I know, many Pyflink users are still using python 3.7 as their default interpreter. I prefer to deprecate Python 3.7 in 1.19 just like

Re: [VOTE] Apache Flink ML Release 2.3.0, release candidate #1

+1 (binding) - Verified the checksums and GPG files. - Reviewed the website PR. - Check the Python package apache-flink-ml-2.3.0.tar.gz Best, Xingbo Dian Fu 于2023年6月29日周四 19:46写道： > +1 (binding) > > - Verified the checksums and signatures. > - The website PR LGTM > > Regards, > Dian > > On

Re: [VOTE] Release 1.16.2, release candidate #1

+1 (binding) - verify signatures and checksums - verify python wheel package contents - pip install apache-flink-libraries and apache-flink wheel packages - run example flink/flink-python/pyflink/examples/table/basic_operations.py with Python 3.7 - reviewed release blog post Best, Xingbo

Re: [VOTE] Release 1.17.1, release candidate #1

+1 (binding) - verify signatures and checksums - verify python wheel package contents - pip install apache-flink-libraries and apache-flink wheel packages - run example flink/flink-python/pyflink/examples/table/basic_operations.py with Python 3.10 - reviewed release blog post Best, Xingbo Yuxin

Re: [VOTE] Apache Flink ML Release 2.2.0, release candidate #2

Thanks Dong for driving this release. +1 (binding) - verify signatures and checksums - pip install apache-flink-ml source package and run simple example - download source code and build from source code - review release notes Best, Xingbo Guowei Ma 于2023年4月14日周五 15:54写道： > Hi Dong, > >

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

+1 (binding) - verify signatures and checksums - verify python wheel package contents - pip install apache-flink-libraries and apache-flink wheel packages - run example flink/flink-python/pyflink/examples/table/basic_operations.py with Python 3.10 - reviewed release note PR Best, Xingbo Sergey

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

+1 (binding) - checked signatures and checksums of binaries - reviewed release blog post - verify python wheel package contents - run the examples from Python Table API tutorial Thanks for preparing this rc! Xingbo Samrat Deb 于2023年3月14日周二 10:16写道： > +1 (non binding) > > - checked AWS

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

+1 for extending the freeze date to Jan 31st Best, Xingbo Jingsong Li 于2023年1月3日周二 17:58写道： > +1 > > On Tue, Jan 3, 2023 at 4:40 PM Matthias Pohl > wrote: > > > > +1 for extending to Jan 31 > > > > On Tue, Jan 3, 2023 at 8:33 AM Yu Li wrote: > > > > > +1 for the proposal (extending the 1.17

[jira] [Created] (FLINK-30366) Python Group Agg failed in cleaning the idle state

Xingbo Huang created FLINK-30366: Summary: Python Group Agg failed in cleaning the idle state Key: FLINK-30366 URL: https://issues.apache.org/jira/browse/FLINK-30366 Project: Flink Issue

[jira] [Created] (FLINK-30169) Adds version switcher in PyFlink API doc

Xingbo Huang created FLINK-30169: Summary: Adds version switcher in PyFlink API doc Key: FLINK-30169 URL: https://issues.apache.org/jira/browse/FLINK-30169 Project: Flink Issue Type: Sub

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

Congrats Matyas! Best, Xingbo Yanfei Lei 于2022年11月22日周二 11:18写道： > Congrats Matyas!  > > Zheng Yu Chen 于2022年11月22日周二 11:15写道： > > > Congratulations ~  > > > > Márton Balassi 于2022年11月21日周一 22:18写道： > > > > > Hi everyone, > > > > > > On behalf of the PMC, I'm very happy to announce Matyas

Re: [DISCUSS] Flink release retro

Thanks for starting the discussion, Matthias! When I was the 1.16 release manager, I checked the dev mailing list to see what the release managers of the previous two versions did throughout the release cycle. In release 1.16, after each release sync meeting, we would send a summary email, which

[ANNOUNCE] Apache Flink 1.16.0 released

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

[RESULT] [VOTE] Release 1.16.0, release candidate #2

Hi everyone, I am pleased to announce that we have unanimously approved this release candidate: There are 14 approving votes, 3 of which are binding: - Xintong （binding) - Yun Tang (non-binding) - Lijie (non-binding) - Xingbo (non-binding) - Leonard Xu (non-binding) - Sergey (non-binding) -

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

gt;>>On Mon, Oct 24, 2022 at 4:54 PM Matthias Pohl > > > >>> wrote: > > > >>> > > > >>>> +1 (non-binding) > > > >>>> > > > >>>> * Downloaded artifacts > > > >>>> * Verified

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

t; > > > for Sink topology with Global Committer. The problem was > > described > > > by > > > > > me > > > > > > in > > > > > > > this thread [1]. We need all three to fix the problem. > > > > > >

Re: [DISCUSS] Planning Flink 1.17

Thanks Qingsheng, Leonard and Martijn for starting the discussion and volunteering. The timeline proposal sounds reasonable :+1: Best, Xingbo Jark Wu 于2022年10月21日周五 00:17写道： > Thanks for kicking off the 1.17 release. > > Targeting feature freeze on 1/17 for 1.17 release sounds pretty good to

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

> 1.16 > > > > release branch today but I do not see it on the change list. > > > > > > > > It is closely related to [3] and [4] that are on the change list. > > However > > > > to fully fix Sink architecture issue we need all 3 t

[VOTE] Release 1.16.0, release candidate #2

Hi everyone, Please review and vote on the release candidate #2 for the version 1.16.0, 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 includes: * JIRA release notes [1],

Re: [VOTE] Reverting sink metric name changes made in 1.15

+1 Best, Xingbo Xintong Song 于2022年10月14日周五 11:42写道： > +1 (binding) > > Best, > > Xintong > > > > On Fri, Oct 14, 2022 at 11:19 AM Jark Wu wrote: > > > Thanks a lot for driving this, Qingsheng! > > > > +1 (binding) > > > > > > Best, > > Jark > > > > On Fri, 14 Oct 2022 at 10:16, Hang Ruan

Re: [ANNOUNCE] New Apache Flink PMC Member - Danny Cranmer

Congratulations Danny! Best, Xingbo Sergey Nuyanzin 于2022年10月12日周三 01:26写道： > Congratulations, Danny > > On Tue, Oct 11, 2022, 15:18 Lincoln Lee wrote: > > > Congratulations Danny! > > > > Best, > > Lincoln Lee > > > > > > Congxian Qiu 于2022年10月11日周二 19:42写道： > > > > > Congratulations Danny!

[SUMMARY] Flink 1.16 release sync of 2022-10-11

I would like to give you a brief update of the Flink 1.16 release sync meating of 2022-10-11. *rc1 is canceled because we found a metric compatibility change, which is expected to be fixed before Thursday https://issues.apache.org/jira/browse/FLINK-29567. We will prepare rc2 once this blocker

Re: [VOTE] Release 1.16.0, release candidate #1

d be part > > of the > > >>> > section where we create the release branch. But cannot find the > > >>> pointer. > > >>> > > > >>> > [1] > > >>> > > > >>> > > > https://cwiki.apache.org/con

Re: [DISCUSS] Reverting sink metric name changes made in 1.15

+1 for reverting these changes in Flink 1.16, so I will cancel 1.16.0-rc1. +1 for `numXXXSend` as the alias of `numXXXOut` in 1.15.3. Best, Xingbo Chesnay Schepler 于2022年10月10日周一 19:13写道： > > I’m with Xintong’s idea to treat numXXXSend as an alias of numXXXOut > > But that's not possible. If

[SUMMARY] Flink 1.16 release sync of 2022-10-04

I would like to give you a brief update of the Flink 1.16 release sync meating of 2022-10-04. *We have prepared rc1 last Friday. Looking forward to your testing.* *This week is Chinese National Day holiday, so the release time maybe a week later than expected* *We still have some critical test

[jira] [Created] (FLINK-29495) PulsarSinkE2ECase hang

Xingbo Huang created FLINK-29495: Summary: PulsarSinkE2ECase hang Key: FLINK-29495 URL: https://issues.apache.org/jira/browse/FLINK-29495 Project: Flink Issue Type: Bug Components

[VOTE] Release 1.16.0, release candidate #1

Hi everyone, Please review and vote on the release candidate #1 for the version 1.16.0, 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 includes: * JIRA release notes [1],

[ANNOUNCE] Apache Flink 1.14.6 released

The Apache Flink community is very happy to announce the release of Apache Flink 1.14.6, which is the fifth bugfix release for the Apache Flink 1.14 series. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data streaming

[SUMMARY] Flink 1.16 release sync of 2022-09-27

I would like to give you a brief update of the Flink 1.16 release sync meating of 2022-09-27. *Currently, there are still 2 blocker issues FLINK-29348, FLINK-29431. Once these two issues are resolved and there are no other new blocking issues, we will start preparing rc1.* *We still have some

[RESULT] [VOTE] Release 1.14.6, release candidate #2

Hi everyone, I am pleased to announce that we have unanimously approved this release candidate: There are 7 approving votes, 3 of which are binding: - Danny Cranmer (non-binding) - Matthias Pohl (non-binding) - Jingsong Li (binding) - Yun Tang (non-binding) - Dian Fu (binding) - Yun Gao

[SUMMARY] Flink 1.16 release sync of 2022-09-20

I would like to give you a brief update of the Flink 1.16 release sync meating of 2022-09-20. *We have created release-1.16 rc0 in last Wednesday(14th of September 2022)* *Currently, there are 3 blocker issues which are being worked on. Many thanks to these contributors and reviewers. -

[ANNOUNCE] Release 1.16.0, release candidate #0

Hi everyone, The RC0 for Apache Flink 1.16.0 has been created. This is still a preview-only release candidate to facilitate the integrated testing since there are still some ongoing efforts, thus no official votes will take place. It has all the artifacts that we would typically have for a

[jira] [Created] (FLINK-29296) OperatorCoordinatorHolder.create throws NPE

Xingbo Huang created FLINK-29296: Summary: OperatorCoordinatorHolder.create throws NPE Key: FLINK-29296 URL: https://issues.apache.org/jira/browse/FLINK-29296 Project: Flink Issue Type: Bug

[SUMMARY] Flink 1.16 release sync of 2022-09-13

I would like to give you a brief update of the Flink 1.16 release sync meating of 2022-09-13. *We have finished x-team testing and all blocker issues have been fixed, so we will start to prepare rc0* *We still have some critical test stabilities[1] need to be resolved* For more information

[jira] [Created] (FLINK-29274) HiveServer2EndpointITCase.testGetFunctionWithPattern failed with Persistence Manager has been closed

Xingbo Huang created FLINK-29274: Summary: HiveServer2EndpointITCase.testGetFunctionWithPattern failed with Persistence Manager has been closed Key: FLINK-29274 URL: https://issues.apache.org/jira/browse/FLINK

[VOTE] Release 1.14.6, release candidate #2

Hi everyone, Please review and vote on the release candidate #2 for the version 1.14.6, 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 includes: * JIRA release notes [1],

Re: [ANNOUNCE] New Apache Flink PMC Member - Martijn Visser

Congratulations, Martijn! Well deserved. Best, Xingbo Geng Biao 于2022年9月10日周六 18:38写道： > Congrats, Martijn! > Best, > Biao > > 获取 Outlook for iOS > > 发件人: Sergey Nuyanzin > 发送时间: Saturday, September 10, 2022 6:10:01 PM > 收件人:

Re: [SUMMARY] Flink 1.16 release sync of 2022-09-06

at 1.16.0 didn't release yet after I merge > https://github.com/apache/flink/pull/20798 into the release branch. Sorry > for making this change. > > This is a trivial change but if you'd like to revert it, please do it and > comment in the original PR. > > Best, > tison. > &g

Re: [VOTE] Release 1.14.6, release candidate #1

in-scala_2.11.tgz.sha512 > > a2b1cac32778272c1741befa79832056d07977f9b714edccea9c1fdd7f73ba711beb5013c3b5f2794d53f74c3cfcfd19cc3145d86b17644a083edca4be0a4258 > flink-1.14.6-bin-scala_2.11.tgz > > Looks like the sha is not correct. > > Best, > Jingsong > > On Fri, Sep 9, 2022 at 9:56 AM Xingbo Huang wrote: > > > > Hi ev

Re: [ANNOUNCE] New Apache Flink Committer - Caizhi Weng

Congratulations Caizhi Best, Xingbo Jingsong Lee 于2022年9月9日周五 09:41写道： > Hi everyone, > > On behalf of the PMC, I'm very happy to announce Caizhi Weng as a new > Flink committer. > > Caizhi has been contributing to the Flink project for more than 3 > years, and has authored 150+ PRs. He is one

[VOTE] Release 1.14.6, release candidate #1

Hi everyone, Please review and vote on the release candidate #1 for the version 1.14.6, 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 includes: * JIRA release notes [1],

Re: [DISCUSS] Releasing Flink 1.14.6

t; > +1 for 1.14.6 > > > > > > > > Thanks Xingbo for driving. > > > > > > > > Best, > > > > Jingsong > > > > > > > > On Tue, Sep 6, 2022 at 4:42 PM Xingbo Huang > > wrote: > > > > > > &g

[jira] [Created] (FLINK-29220) Skip ci tests on docs-only-PRs

Xingbo Huang created FLINK-29220: Summary: Skip ci tests on docs-only-PRs Key: FLINK-29220 URL: https://issues.apache.org/jira/browse/FLINK-29220 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-29217) CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase.testConcurrentCheckpoint failed with AssertionFailedError

Xingbo Huang created FLINK-29217: Summary: CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase.testConcurrentCheckpoint failed with AssertionFailedError Key: FLINK-29217 URL: https://issues.apache.org

Re: [VOTE] FLIP-258 Guarantee binary compatibility for Public/-Evolving APIs between patch releases​

Thanks Chesnay for driving this, +1 Best, Xingbo Xintong Song 于2022年9月6日周二 17:57写道： > +1 > > Best, > > Xintong > > > > On Tue, Sep 6, 2022 at 5:55 PM Konstantin Knauf wrote: > > > +1. Thanks, Chesnay. > > > > Am Di., 6. Sept. 2022 um 11:51 Uhr schrieb Chesnay Schepler < > >

[DISCUSS] Releasing Flink 1.14.6

Hi all, I would like to start discussing releasing Flink 1.14.6. It has already been almost three months since we released 1.14.5. There are currently 35 tickets[1] and 33 commits[2] already resolved for 1.14.6, some of them quite important, such as FLINK-27399

[SUMMARY] Flink 1.16 release sync of 2022-09-06

I would like to give you a brief update of the Flink 1.16 release sync meating of 2022-09-06. *We have cut release-1.16 branch yesterday(5th of September 2022). It is expected that we will prepare rc0 for further testing in a few days* *We're almost done with x-team testing[1]. The remaining

[jira] [Created] (FLINK-29196) Check 1.16 licensing

Xingbo Huang created FLINK-29196: Summary: Check 1.16 licensing Key: FLINK-29196 URL: https://issues.apache.org/jira/browse/FLINK-29196 Project: Flink Issue Type: Technical Debt

[ANNOUNCE] release-1.16 branch cut

Hi devs, The release-1.16 branch has been forked out from the master branch, at the commit 4b15bc900eb60b1830bc406975ce974ad6050f98. Also, the version on the master branch has been upgraded to 1.17-SNAPSHOT. >From now on, for PRs that should be presented in 1.16.0, please make sure: - Merge the

Re: [DISCUSS] Switch docker iamge base to Eclipse Temurin

Thanks Chesnay for driving this. I found a problem with image name change[1] and I have created a PR[2] to fix it. Best, Xingbo [1] https://issues.apache.org/jira/browse/FLINK-29161 [2] https://github.com/apache/flink/pull/20726 Chesnay Schepler 于2022年8月31日周三 17:15写道： > I will optimistically

[jira] [Created] (FLINK-29161) Run kubernetes application HA test failed with unable to prepare context: path "dev/test_kubernetes_application_ha-debian" not found

Xingbo Huang created FLINK-29161: Summary: Run kubernetes application HA test failed with unable to prepare context: path "dev/test_kubernetes_application_ha-debian" not found Key: FLINK-29161

[jira] [Created] (FLINK-29155) Improve default config of grpcServer in Process Mode

Xingbo Huang created FLINK-29155: Summary: Improve default config of grpcServer in Process Mode Key: FLINK-29155 URL: https://issues.apache.org/jira/browse/FLINK-29155 Project: Flink Issue

[jira] [Created] (FLINK-29147) ChangelogLocalRecoveryITCase.testRestartTM failed with CheckpointException

Xingbo Huang created FLINK-29147: Summary: ChangelogLocalRecoveryITCase.testRestartTM failed with CheckpointException Key: FLINK-29147 URL: https://issues.apache.org/jira/browse/FLINK-29147 Project

[SUMMARY] Flink 1.16 release sync of 2022-08-30

I would like to give you a brief update of the Flink 1.16 release sync meating of 2022-08-30. *Since the feature freeze(9th of August 2022, end of business CEST), we have started release-testing[1] in the last three weeks. We're almost done with half of the test issues. The remaining test issues

[jira] [Created] (FLINK-29105) KubernetesStateHandleStoreTest.testAddAndLockShouldNotThrowAlreadyExistExceptionWithSameContents failed with AssertionFailedError

Xingbo Huang created FLINK-29105: Summary: KubernetesStateHandleStoreTest.testAddAndLockShouldNotThrowAlreadyExistExceptionWithSameContents failed with AssertionFailedError Key: FLINK-29105 URL: https

Re: [ANNOUNCE] Apache Flink 1.15.2 released

Thanks Danny for driving this release Best, Xingbo Jing Ge 于2022年8月25日周四 05:50写道： > Thanks Danny for your effort! > > Best regards, > Jing > > On Wed, Aug 24, 2022 at 11:43 PM Danny Cranmer > wrote: > >> The Apache Flink community is very happy to announce the release of >> Apache Flink

[jira] [Created] (FLINK-29102) ChangelogLocalRecoveryITCase.testRestartTM failed with AssertionFailedError

Xingbo Huang created FLINK-29102: Summary: ChangelogLocalRecoveryITCase.testRestartTM failed with AssertionFailedError Key: FLINK-29102 URL: https://issues.apache.org/jira/browse/FLINK-29102 Project

[jira] [Created] (FLINK-29093) LookupJoinITCase failed with InternalCompilerException

Xingbo Huang created FLINK-29093: Summary: LookupJoinITCase failed with InternalCompilerException Key: FLINK-29093 URL: https://issues.apache.org/jira/browse/FLINK-29093 Project: Flink Issue

[jira] [Created] (FLINK-29092) HadoopPathBasedPartFileWriterTest.testWriteFile failed with AssertionError

Xingbo Huang created FLINK-29092: Summary: HadoopPathBasedPartFileWriterTest.testWriteFile failed with AssertionError Key: FLINK-29092 URL: https://issues.apache.org/jira/browse/FLINK-29092 Project

[SUMMARY] Flink 1.16 release sync of 2022-08-23

I would like to give you a brief update of the Flink 1.16 release sync meating of 2022-08-23. *Since the feature freeze(9th of August 2022, end of business CEST), we have started release-testing[1] in the last two weeks. Only two tickets have been completed so far. We hope that the testers of the

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

+1 (non-binding) - verify signatures and checksums - no binaries found in source archive - reviewed the release note blog - verify python wheel package contents - pip install apache-flink-libraries and apache-flink wheel packages - run the examples from Python Table API tutorial Best, Xingbo

Re: [ANNOUNCE] New Apache Flink Committer - Lijie Wang

Congrats, Lijie Best, Xingbo Lincoln Lee 于2022年8月18日周四 11:01写道： > Congratulations, Lijie! > > Best, > Lincoln Lee > > > Benchao Li 于2022年8月18日周四 10:51写道： > > > Congratulations Lijie! > > > > yanfei lei 于2022年8月18日周四 10:44写道： > > > > > Congratulations, Lijie! > > > > > > Best, > > > Yanfei >

[SUMMARY] Flink 1.16 release sync of 2022-08-16

Hi everyone, I would like to give you a brief update of the Flink 1.16 release sync meating of 2022-08-16. *In the last Wednesday(9th of August 2022, end of business CEST), we announced the feature freeze. And after that, we have started release testing work. I have created an umbrella release

Re: [DISCUSS] Releasing Flink 1.15.2

Hi Danny, Thanks for driving the release. +1 for the 1.15.2 release. Best, Xingbo Chesnay Schepler 于2022年8月11日周四 20:06写道： > I think that's a good idea; a user in the Flink slack was asking for it > just yesterday. > > About FLINK-28861, let's wait a day or something because there should be >

[jira] [Created] (FLINK-28901) CassandraSinkBaseTest.testTimeoutExceptionOnInvoke failed with TestTimedOutException

Xingbo Huang created FLINK-28901: Summary: CassandraSinkBaseTest.testTimeoutExceptionOnInvoke failed with TestTimedOutException Key: FLINK-28901 URL: https://issues.apache.org/jira/browse/FLINK-28901

[jira] [Created] (FLINK-28900) RecreateOnResetOperatorCoordinatorTest compile failed in jdk11

Xingbo Huang created FLINK-28900: Summary: RecreateOnResetOperatorCoordinatorTest compile failed in jdk11 Key: FLINK-28900 URL: https://issues.apache.org/jira/browse/FLINK-28900 Project: Flink

[jira] [Created] (FLINK-28898) ChangelogRecoverySwitchStateBackendITCase.testSwitchFromEnablingToDisablingWithRescalingOut failed

Xingbo Huang created FLINK-28898: Summary: ChangelogRecoverySwitchStateBackendITCase.testSwitchFromEnablingToDisablingWithRescalingOut failed Key: FLINK-28898 URL: https://issues.apache.org/jira/browse/FLINK

Re: [DISCUSS] Bump Kafka to 3.2.1 for 1.16.0

I'm not sure if this kafka upgrade will bring other unknown problems, but if this upgrade can help us solve known critical bugs, the sooner the upgrade, the better. Before cutting release-1.16 branch, we will still have enough time to test the impact. So I'm +1 for including this fix in 1.16.0.

[SUMMARY] Flink 1.16 release sync of 2022-08-09

Hi everyone, I would like to give you a brief update of the Flink 1.16 release sync meating of 2022-08-09. * Currently, we have 40 features that have been completed for this release and 6 features are still expected to make it (PS: Most of them are already reviewed and are just waiting for the

Re: [SUMMARY] Flink 1.16 release sync of 2022-08-02

cker (FLINK-27399) is still open, but the PR > > seems to make progress. > > > > On Wed, Aug 3, 2022 at 6:46 AM Xingbo Huang wrote: > > > >> Hi everyone, > >> > >> I would like to give you a brief update of the Flink 1.16 release sync > >> mea

[jira] [Created] (FLINK-28788) Support SideOutput in Thread Mode

Xingbo Huang created FLINK-28788: Summary: Support SideOutput in Thread Mode Key: FLINK-28788 URL: https://issues.apache.org/jira/browse/FLINK-28788 Project: Flink Issue Type: New Feature

[SUMMARY] Flink 1.16 release sync of 2022-08-02

Hi everyone, I would like to give you a brief update of the Flink 1.16 release sync meating of 2022-08-02. Currently, we have 19 features that have been completed for this release and 32 features are still expected to make it. We only have one week remaining until the feature freeze (at

Re: I want to contribute to Apache Flink.

Hi, Thanks for reaching out. Please follow https://flink.apache.org/contributing/contribute-code.html to start with your contribution. You don't need to be in any list to start your contribution. Best, Xingbo 黄如飞 <1369612...@qq.com.invalid> 于2022年7月28日周四 11:25写道： > Hi Guys, > I want to

[SUMMARY] Flink 1.16 release sync of 2022-07-26

Hi everyone, I would like to give you a brief update of the Flink 1.16 release sync meating of 2022-07-26. Currently, we have 17 features that have been completed for this release and 35 features are still expected to make it. We only have 2 weeks remaining until the feature freeze (at

[SUMMARY] Flink 1.16 release sync of 2022-07-19

Hi everyone, I would like to give you a brief update of the Flink 1.16 release status till 2022-07-19. Currently, we have 12 features that have been completed for this release and 41 features are still expected to make it. We only have 3 weeks remaining until the feature freeze (at 2022-08-09).

Re: [DISCUSS] Creating benchmark channel in Apache Flink slack

+1 for creating a public slack channel for benchmark. Like the build channel, it will help us find potential problems before release. Best, Xingbo Jing Ge 于2022年7月7日周四 22:41写道： > +1 for moving to the public slack channel. Flink developers should pay more > attention to the performance test. >

Re: [ANNOUNCE] Apache Flink 1.15.1 released

Thanks a lot for being our release manager David and everyone who contributed. Best, Xingbo David Anderson 于2022年7月8日周五 06:18写道： > The Apache Flink community is very happy to announce the release of Apache > Flink 1.15.1, which is the first bugfix release for the Apache Flink 1.15 > series. >

Re: [ACTION REQUESTED] Flink 1.16 Release Sync update

Hi Martjin, I have discussed offline with several contributors from China and found that most of them thought it difficult to finish the on-going features by 25th July. As there is consensus[1][2] that the feature freeze will happen by the end of July with potentially two weeks delay, do you

Re: [VOTE] Release 1.15.1, release candidate #1

+1 (non-binding) - verify signatures and checksums - no binaries found in source archive - build from source - Reviewed the release note blog - verify python wheel package contents - pip install apache-flink-libraries and apache-flink wheel packages - run the examples from Python Table API

Re: [DISCUSS] Releasing Flink ML 2.1.0

Hi Yun and Zhipeng, Thanks a lot for starting the discussion. +1 for the FLINK ML 2.1.0 release. Looking forward for these ML algorithms. I plan to write a blog about PyFlink + Flink ML after the released. Best, Xingbo Zhipeng Zhang 于2022年6月23日周四 11:15写道： > Hi devs, > > Yun and I would like

[ANNOUNCE] Apache Flink 1.14.5 released

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® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data streaming

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

Congrats, Qingsheng and Shengkai! Best, Xingbo Dian Fu 于2022年6月20日周一 18:52写道： > Congratulations, Qingsheng and ShengKai! > > Regards, > Dian > > On Mon, Jun 20, 2022 at 5:41 PM Lincoln Lee > wrote: > > > Congrats, Qingsheng and Shengkai! > > > > > > Best, > > Lincoln Lee > > > > > > Sergey

[RESULT] [VOTE] Release 1.14.5, release candidate #1

Hi everyone, I am pleased to announce that we have unanimously approved this release candidate: There are 6 approving votes, 3 of which are binding: - Konstantin Knauf (binding) - Xingbo Huang (non-binding) - Dian Fu (binding) - Shuiqiang Chen (non-binding) - Lijie Wang (non-binding) - Yun Gao

Re: [VOTE] Release 1.14.5, release candidate #1

this rc! > > Konstantin > > > Am Fr., 10. Juni 2022 um 11:58 Uhr schrieb Xingbo Huang < > hxbks...@gmail.com > >: > > > Hi everyone, > > > > Please review and vote on the release candidate #1 for the version > 1.14.5, > > as follows: >

Re: [VOTE] FLIP-228: Support Within between events in CEP Pattern

+1 (binding) Best, Xingbo Dian Fu 于2022年6月13日周一 16:08写道： > +1 (binding) > > Regards, > Dian > > On Mon, Jun 13, 2022 at 3:55 PM Rui Fan <1996fan...@gmail.com> wrote: > > > Thanks for Nicholas driving this. > > > > +1(non-binding) > > > > Best, > > Rui Fan > > > > On Mon, Jun 13, 2022 at 3:05

Re: [ANNOUNCE] New Apache Flink PMC Member - Jingsong Lee

Congratulations, Jingsong! Best, Xingbo Jane Chan 于2022年6月13日周一 17:23写道： > Congratulations, Jingsong! > > Best, > Jane Chan > > On Mon, Jun 13, 2022 at 4:43 PM Shuo Cheng wrote: > > > Congratulations, Jingsong! > > > > On 6/13/22, Paul Lam wrote: > > > Congrats, Jingsong! Well deserved! > >

[VOTE] Release 1.14.5, release candidate #1

Hi everyone, Please review and vote on the release candidate #1 for the version 1.14.5, 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 includes: * JIRA release notes [1],

Re: [DISCUSS] Releasing 1.15.1

Hi David, +1 Thank you for driving this. Best, Xingbo Chesnay Schepler 于2022年6月8日周三 18:41写道： > +1 > > Thank you for proposing this. I can take care of the PMC-side of things. > > On 08/06/2022 12:37, Jingsong Li wrote: > > +1 > > > > Thanks David for volunteering to manage the release. > > >

Re: [DISCUSS] Releasing Flink 1.14.5

ere are already > > nearly > > > 100 commits [1] since 1.14.4. > > > > > > Regards, > > > Dian > > > > > > [1] > > https://github.com/apache/flink/compare/release-1.14.4...release-1.14 > > > > > > On Tue, May 24, 2022

Re: [ANNOUNCE] Welcome to join the Apache Flink community on Slack

Thanks everyone for the great effort driving this. +1 for building a dedicated channel for CI builds. Best, Xingbo Martijn Visser 于2022年6月8日周三 01:32写道： > Hi Matthias, > > I've only thought about it, but I absolutely would +1 this. Making this > information available in dedicated channels will

[DISCUSS] Releasing Flink 1.14.5

Hi all, I would like to start discussing releasing Flink 1.14.5. It has already been more than two months since we released 1.14.4. There are currently 62 tickets[1] already resolved for 1.14.5, some of them quite severe. Currently, there are no issues marked as critical or blocker for 1.14.5.

Re: [DISCUSS] Planning Flink 1.16

Thanks Konstantin and Chesnay for starting the discussion. I'm also willing to volunteer as the release manager if this is still open. Regarding the feature freeze date, +1 to the end of mid August. Best, Xingbo Zhu Zhu 于2022年4月29日周五 11:01写道： > +1 for a 5 months release cycle. > +1 target the

Re: [VOTE] Release 1.15.0, release candidate #4

+1 (non-binding) - Verified checksums and signatures - Verified Python wheel package contents - Pip install apache-flink-libraries source package and apache-flink wheel package in Mac/Linux - Run the examples from Python Table API Tutorial in Python REPL - Test the Python UDF jobs in Thread Mode.

Re: Issue while running word_count.py

Hi Rohith, I guess the `word_count.py` you tried to execute is from flink release-1.15 or master branch. For pyflink 1.14 you are using, you need to change `t_env.get_config().set_string("parallelism.default", "1")` to `t_env.get_config().get_configuration().set_string("parallelism.default",

Re: pyflink on Python 3.9 dev guide

exits with code: 1 > at > org.apache.flink.client.python.PythonDriver.main(PythonDriver.java:130) > ~[?:?] > ... 13 more > org.apache.flink.client.program.ProgramAbortException: > java.lang.RuntimeException: Python process exits with code: 1 > at > org.apache.flink.client.python.PythonDriver.main(Pytho

Re: Regarding java.lang.NullPointerException

Hi Josemon, Can you provide the version of PyFlink you are using, and it would be better if you can also provide code snippets that can be easily reproduced this problem. Best, Xingbo Josemon Maliakal 于2022年4月5日周二 13:31写道： > Hello There, > I started using pyflink recently, > Have anyone know

  1   2   3   >