Re: [DISCUSS] FLIP-171: Async Sink

Hey Steffen, I have a few questions regarding the FLIP: 1. Where do you expect the core code to live, would it be in an existing module (say flink-clients) or would you introduce a new module? 2. Which destination implementations do you intend to ship with this FLIP? I see an example with Kines

Re: [ANNOUNCE] Welcome Guowei Ma as a new Apache Flink Committer

Congratulations Guowei!! On 20/01/2021, 05:35, "Kurt Young" wrote: CAUTION: This email originated from outside of the organization. Do not click links or open attachments unless you can confirm the sender and know the content is safe. Hi everyone, I'm very happy to announce th

Re: [ANNOUNCE] Welcome Danny Cranmer as a new Apache Flink Committer

Thankyou everyone for the welcome! I look forward to working with more of you in the near future. Danny, On 13/01/2021, 07:38, "Yun Gao" wrote: CAUTION: This email originated from outside of the organization. Do not click links or open attachments unless you can confirm the sender and kn

Re: [ANNOUNCE] New PMC member: Dian Fu

Congratulations Dian! :D On 27/08/2020, 15:25, "Robert Metzger" wrote: CAUTION: This email originated from outside of the organization. Do not click links or open attachments unless you can confirm the sender and know the content is safe. Congratulations Dian! On Thu, Aug

Re: [DISCUSS] FLIP-128: Enhanced Fan Out for AWS Kinesis Consumers

latest/dev/service-sizes-and-limits.html On Mon, Jun 22, 2020 at 2:42 AM Cranmer, Danny wrote: > Hello everyone, > This is a discussion thread for the FLIP [1] regarding Enhanced Fan Out > for AWS Kinesis Consumers. > > Enhanced Fan Out (EFO) allows AWS Kines

Re: [VOTE] FLIP-128: Enhanced Fan Out for AWS Kinesis Consumers

t 12:15 AM Konstantin Knauf wrote: > +1 > > On Thu, Jul 2, 2020 at 8:16 PM Aljoscha Krettek > wrote: > > > +1 > > > > Aljoscha > > > > On 01.07.20 15:14, Tzu-Li (Gordon) Tai wrote: > > > +1 > >

[VOTE] FLIP-128: Enhanced Fan Out for AWS Kinesis Consumers

Hi all, I'd like to start a voting thread for FLIP-128 [1], which we've reached consensus in [2]. This voting will be open for minimum 3 days till 13:00 UTC, July 4th. Thanks, Danny Cranmer [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-128%3A+Enhanced+Fan+Out+for+AWS+Kinesis+Cons

Re: [DISCUSS] FLIP-128: Enhanced Fan Out for AWS Kinesis Consumers

art-up and teardown AWS SDK calls. Let me know if you are happy to proceed to a vote or have any further feedback. Thanks, Danny Cranmer [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-128%3A+Enhanced+Fan+Out+for+AWS+Kinesis+Consumers On 29/06/2020, 15:28, "Cranmer, Danny" wr

Re: [DISCUSS] FLIP-128: Enhanced Fan Out for AWS Kinesis Consumers

Hey Gordon, Thank-you for you review and feedback. I agree with your suggestion for the contribution plan. I have updated the FLIP to include the additional step with the FanOutKinesisProxy/AWS SDK 2.x dependency. I have also added another precursor step to generally improve test coverage. I

[DISCUSS] FLIP-128: Enhanced Fan Out for AWS Kinesis Consumers

Hello everyone, This is a discussion thread for the FLIP I have recently created: * FLIP-128: Enhanced Fan Out for AWS Kinesis Consumers * https://issues.apache.org/jira/browse/FLINK

[DISCUSS] FLIP-128: Enhanced Fan Out for AWS Kinesis Consumers

Hello everyone, This is a discussion thread for the FLIP [1] regarding Enhanced Fan Out for AWS Kinesis Consumers. Enhanced Fan Out (EFO) allows AWS Kinesis Data Stream (KDS) consumers to utilise a dedicated read throughput, rather than a shared quota. HTTP/2 reduces latency and typically gives