flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Khachatryan Roman <khachatryan.ro...@gmail.com>
Subject Re: MongoSink
Date Mon, 11 May 2020 18:09:15 GMT
Hi Aissa,

What is BSONWritable you pass from map to sink?
I guess it's not serializable which causes Flink to use kryo, which fails.

Regards,
Roman


On Sun, May 10, 2020 at 10:42 PM Aissa Elaffani <aissaelaffani@gmail.com>
wrote:

> Hello Guys,
> I am trying to sink my data to MongoDB, But i got some errors. I am
> sharing with you my MongoDB implemetation, and the errors that occurred. I
> hope someone can figure it out.
> Thank you for your time, I really appreciate it.
> Aissa
>

Mime
View raw message