[jira] [Created] (FLINK-28664) Support AvroWriters in PyFlink

2022-07-24 Thread Juntao Hu (Jira)
Juntao Hu created FLINK-28664: - Summary: Support AvroWriters in PyFlink Key: FLINK-28664 URL: https://issues.apache.org/jira/browse/FLINK-28664 Project: Flink Issue Type: New Feature Co

[jira] [Created] (FLINK-28663) Allow multiple downstream consumer job vertices sharing the same intermediate dataset at scheduler side

2022-07-24 Thread Yingjie Cao (Jira)
Yingjie Cao created FLINK-28663: --- Summary: Allow multiple downstream consumer job vertices sharing the same intermediate dataset at scheduler side Key: FLINK-28663 URL: https://issues.apache.org/jira/browse/FLINK-28

Re: [DISCUSS] FLIP-217 Support watermark alignment of source splits

2022-07-24 Thread Sebastian Mattheis
Hi everybody, I discussed last week the semantics and an implementation stragegy of the configuration parameter with Piotr and did the implementation and some tests this weekend. A short summary of what I discussed and recapped with Piotr: - The configuration parameter allows (and tolerates)

Re: Re: [VOTE] FLIP-252: Amazon DynamoDB Sink Connector

2022-07-24 Thread Becket Qin
+1 On Mon, Jul 25, 2022 at 9:22 AM Grant L (Grant) wrote: > +1 > > On 2022/07/21 18:27:52 Robert Metzger wrote: > > +1 > > > > On Wed, Jul 20, 2022 at 10:48 PM Konstantin Knauf > wrote: > > > > > +1. Thanks! > > > > > > Am Mi., 20. Juli 2022 um 16:48 Uhr schrieb Tzu-Li (Gordon) Tai < > > > tzul

Re: [VOTE] FLIP-250: Support Customized Kubernetes Schedulers Proposal

2022-07-24 Thread Yang Wang
+1 (binding) Best, Yang bo zhaobo 于2022年7月25日周一 09:38写道: > Hi all, > > Thank you very much for all feedback after the discussion in [2][3]. > Now I'd like to proceed with the vote for FLIP-250 [1], as no more > objections > or issues were raised in ML thread [2][3]. > > The vote will be opened

Re: [ANNOUNCE] Apache Flink Kubernetes Operator 1.1.0 released

2022-07-24 Thread Yang Wang
Congrats! Thanks Gyula for driving this release, and thanks to all contributors! Best, Yang Gyula Fóra 于2022年7月25日周一 10:44写道: > The Apache Flink community is very happy to announce the release of Apache > Flink Kubernetes Operator 1.1.0. > > The Flink Kubernetes Operator allows users to manage

[jira] [Created] (FLINK-28662) Compaction may block job cancelling

2022-07-24 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-28662: --- Summary: Compaction may block job cancelling Key: FLINK-28662 URL: https://issues.apache.org/jira/browse/FLINK-28662 Project: Flink Issue Type: Improvement

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

2022-07-24 Thread Yang Wang
+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

[ANNOUNCE] Apache Flink Kubernetes Operator 1.1.0 released

2022-07-24 Thread Gyula Fóra
The Apache Flink community is very happy to announce the release of Apache Flink Kubernetes Operator 1.1.0. The Flink Kubernetes Operator allows users to manage their Apache Flink applications and their lifecycle through native k8s tooling like kubectl. Please check out the release blog post for

[jira] [Created] (FLINK-28661) Introduce generic mode for table store catalog

2022-07-24 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-28661: Summary: Introduce generic mode for table store catalog Key: FLINK-28661 URL: https://issues.apache.org/jira/browse/FLINK-28661 Project: Flink Issue Type: Ne

[VOTE] FLIP-250: Support Customized Kubernetes Schedulers Proposal

2022-07-24 Thread bo zhaobo
Hi all, Thank you very much for all feedback after the discussion in [2][3]. Now I'd like to proceed with the vote for FLIP-250 [1], as no more objections or issues were raised in ML thread [2][3]. The vote will be opened until July 28th earliest(at least 72 hours) unless there is an objection or

RE: Re: [VOTE] FLIP-252: Amazon DynamoDB Sink Connector

2022-07-24 Thread Grant L (Grant)
+1 On 2022/07/21 18:27:52 Robert Metzger wrote: > +1 > > On Wed, Jul 20, 2022 at 10:48 PM Konstantin Knauf wrote: > > > +1. Thanks! > > > > Am Mi., 20. Juli 2022 um 16:48 Uhr schrieb Tzu-Li (Gordon) Tai < > > tzuli...@apache.org>: > > > > > +1 > > > > > > On Wed, Jul 20, 2022 at 6:13 AM Danny C

RE: Re: [VOTE] FLIP-252: Amazon DynamoDB Sink Connector

2022-07-24 Thread Grant L (Grant)
+1, we need this asap. Thank you so much! On 2022/07/21 18:27:52 Robert Metzger wrote: > +1 > > On Wed, Jul 20, 2022 at 10:48 PM Konstantin Knauf wrote: > > > +1. Thanks! > > > > Am Mi., 20. Juli 2022 um 16:48 Uhr schrieb Tzu-Li (Gordon) Tai < > > tzuli...@apache.org>: > > > > > +1 > > > > > >

Re: [DISCUSS] FLIP-250: Support Customized Kubernetes Schedulers Proposal

2022-07-24 Thread bo zhaobo
Hi Marjtin, Thank you very much that all clear. I will raise a Vote for this then. ;-) BR Bo Zhao Martijn Visser 于2022年7月24日周日 01:42写道: > Hi all, > > Thanks a lot for clarifying Yikun! I have no more concerns. > > Best regards, > > Martijn > > Op vr 22 jul. 2022 om 10:42 schreef bo zhaobo >:

[jira] [Created] (FLINK-28660) Simplify logs of blocklist

2022-07-24 Thread Lijie Wang (Jira)
Lijie Wang created FLINK-28660: -- Summary: Simplify logs of blocklist Key: FLINK-28660 URL: https://issues.apache.org/jira/browse/FLINK-28660 Project: Flink Issue Type: Sub-task Compone

[jira] [Created] (FLINK-28659) [JUnit5 Migration] Module: flink-java

2022-07-24 Thread RocMarshal (Jira)
RocMarshal created FLINK-28659: -- Summary: [JUnit5 Migration] Module: flink-java Key: FLINK-28659 URL: https://issues.apache.org/jira/browse/FLINK-28659 Project: Flink Issue Type: Improvement

[RESULT] [VOTE] Apache Flink Kubernetes Operator Release 1.1.0, release candidate #1

2022-07-24 Thread Gyula Fóra
Hi Devs! I'm happy to announce that we have unanimously approved this release. There are 5 approving votes, 3 of which are binding: * Gyula Fora (binding) * Marton Balassi (binding) * Thomas Weise (binding) * Biao Geng (non-binding) * Jim Busche (non-binding) There are no disapproving votes. T