DynamoDB sink

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

DynamoDB sink

Lorenzo Nicora
Hi

I was wondering whether there is any reasonably optimised DynamoDB Sink 
I am surprised I only found some old, partial discussions about implementing your own one. 

Am I the only one with the requirement of sending output to DynamoDB? 
Am I missing something obvious? 
I am obviously looking for an idempotent, at-least-once sink.

Cheers
Lorenzo
Reply | Threaded
Open this post in threaded view
|

Re: DynamoDB sink

rmetzger0
Hi Lorenzo,

I'm not aware of any well-maintained DynamoDB Sink for Flink. I created a JIRA ticket to track requests for it earlier this year: https://issues.apache.org/jira/browse/FLINK-16504


On Fri, Jul 17, 2020 at 5:40 PM Lorenzo Nicora <[hidden email]> wrote:
Hi

I was wondering whether there is any reasonably optimised DynamoDB Sink 
I am surprised I only found some old, partial discussions about implementing your own one. 

Am I the only one with the requirement of sending output to DynamoDB? 
Am I missing something obvious? 
I am obviously looking for an idempotent, at-least-once sink.

Cheers
Lorenzo