You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Jing Lu <aj...@gmail.com> on 2021/10/28 18:40:26 UTC
Flink connector sink for DynamoDB (Java8)
Hi folks,
Is there any package for writing from flink stream to DynamoDB?
I checked:
https://github.com/klarna-incubator/flink-connector-dynamodb
but, it supports Java11 only. My Java runtime is Java8.
Thanks,
Jing
Re: Flink connector sink for DynamoDB (Java8)
Posted by Arvid Heise <ar...@apache.org>.
You can fork the repo into your github account (or download and import in
your git hosting solution). Then change
https://github.com/klarna-incubator/flink-connector-dynamodb/blob/master/pom.xml#L54
to 8 and try to build it. Fix whatever pops up - it should be minor things;
stackoverflow usually helps.
On Sun, Oct 31, 2021 at 7:26 AM Jing Lu <aj...@gmail.com> wrote:
> Hi Arvid,
>
> Thanks for the suggestion. Sorry to ask a trivial question 😂. How to
> backport klarna connector to Java 8?
>
>
> Thanks,
> Jing
>
> On Sat, Oct 30, 2021 at 5:58 AM Arvid Heise <ar...@apache.org> wrote:
>
>> I have also found [1]. You could also fork the klarna connector and
>> backport it to Java 8.
>>
>> [1]
>> https://flink-packages.org/packages/streaming-flink-dynamodb-connector
>>
>> On Thu, Oct 28, 2021 at 10:04 PM Martijn Visser <ma...@ververica.com>
>> wrote:
>>
>>> Hi,
>>>
>>> I am not aware of any at the moment. There is an open Flink ticket for
>>> it [1] which I believe is targeted for Flink 1.15
>>>
>>> Best regards,
>>>
>>> Martijn
>>>
>>> [1]
>>> https://issues.apache.org/jira/browse/FLINK-24229
>>>
>>> Op do 28 okt. 2021 om 20:41 schreef Jing Lu <aj...@gmail.com>
>>>
>>>> Hi folks,
>>>>
>>>> Is there any package for writing from flink stream to DynamoDB?
>>>>
>>>> I checked:
>>>> https://github.com/klarna-incubator/flink-connector-dynamodb
>>>> but, it supports Java11 only. My Java runtime is Java8.
>>>>
>>>>
>>>> Thanks,
>>>> Jing
>>>>
>>> --
>>>
>>> Martijn Visser | Product Manager
>>>
>>> martijn@ververica.com
>>>
>>> <https://www.ververica.com/>
>>>
>>>
>>> Follow us @VervericaData
>>>
>>> --
>>>
>>> Join Flink Forward <https://flink-forward.org/> - The Apache Flink
>>> Conference
>>>
>>> Stream Processing | Event Driven | Real Time
>>>
>>>
Re: Flink connector sink for DynamoDB (Java8)
Posted by Jing Lu <aj...@gmail.com>.
Hi Arvid,
Thanks for the suggestion. Sorry to ask a trivial question 😂. How to
backport klarna connector to Java 8?
Thanks,
Jing
On Sat, Oct 30, 2021 at 5:58 AM Arvid Heise <ar...@apache.org> wrote:
> I have also found [1]. You could also fork the klarna connector and
> backport it to Java 8.
>
> [1] https://flink-packages.org/packages/streaming-flink-dynamodb-connector
>
> On Thu, Oct 28, 2021 at 10:04 PM Martijn Visser <ma...@ververica.com>
> wrote:
>
>> Hi,
>>
>> I am not aware of any at the moment. There is an open Flink ticket for it
>> [1] which I believe is targeted for Flink 1.15
>>
>> Best regards,
>>
>> Martijn
>>
>> [1]
>> https://issues.apache.org/jira/browse/FLINK-24229
>>
>> Op do 28 okt. 2021 om 20:41 schreef Jing Lu <aj...@gmail.com>
>>
>>> Hi folks,
>>>
>>> Is there any package for writing from flink stream to DynamoDB?
>>>
>>> I checked:
>>> https://github.com/klarna-incubator/flink-connector-dynamodb
>>> but, it supports Java11 only. My Java runtime is Java8.
>>>
>>>
>>> Thanks,
>>> Jing
>>>
>> --
>>
>> Martijn Visser | Product Manager
>>
>> martijn@ververica.com
>>
>> <https://www.ververica.com/>
>>
>>
>> Follow us @VervericaData
>>
>> --
>>
>> Join Flink Forward <https://flink-forward.org/> - The Apache Flink
>> Conference
>>
>> Stream Processing | Event Driven | Real Time
>>
>>
Re: Flink connector sink for DynamoDB (Java8)
Posted by Arvid Heise <ar...@apache.org>.
I have also found [1]. You could also fork the klarna connector and
backport it to Java 8.
[1] https://flink-packages.org/packages/streaming-flink-dynamodb-connector
On Thu, Oct 28, 2021 at 10:04 PM Martijn Visser <ma...@ververica.com>
wrote:
> Hi,
>
> I am not aware of any at the moment. There is an open Flink ticket for it
> [1] which I believe is targeted for Flink 1.15
>
> Best regards,
>
> Martijn
>
> [1]
> https://issues.apache.org/jira/browse/FLINK-24229
>
> Op do 28 okt. 2021 om 20:41 schreef Jing Lu <aj...@gmail.com>
>
>> Hi folks,
>>
>> Is there any package for writing from flink stream to DynamoDB?
>>
>> I checked:
>> https://github.com/klarna-incubator/flink-connector-dynamodb
>> but, it supports Java11 only. My Java runtime is Java8.
>>
>>
>> Thanks,
>> Jing
>>
> --
>
> Martijn Visser | Product Manager
>
> martijn@ververica.com
>
> <https://www.ververica.com/>
>
>
> Follow us @VervericaData
>
> --
>
> Join Flink Forward <https://flink-forward.org/> - The Apache Flink
> Conference
>
> Stream Processing | Event Driven | Real Time
>
>
Re: Flink connector sink for DynamoDB (Java8)
Posted by Martijn Visser <ma...@ververica.com>.
Hi,
I am not aware of any at the moment. There is an open Flink ticket for it
[1] which I believe is targeted for Flink 1.15
Best regards,
Martijn
[1]
https://issues.apache.org/jira/browse/FLINK-24229
Op do 28 okt. 2021 om 20:41 schreef Jing Lu <aj...@gmail.com>
> Hi folks,
>
> Is there any package for writing from flink stream to DynamoDB?
>
> I checked:
> https://github.com/klarna-incubator/flink-connector-dynamodb
> but, it supports Java11 only. My Java runtime is Java8.
>
>
> Thanks,
> Jing
>
--
Martijn Visser | Product Manager
martijn@ververica.com
<https://www.ververica.com/>
Follow us @VervericaData
--
Join Flink Forward <https://flink-forward.org/> - The Apache Flink
Conference
Stream Processing | Event Driven | Real Time