(DEPRECATED) Apache Flink User Mailing List archive.

MongoSink

Classic

List

Threaded

2 messages Options

Aissa Elaffani

MongoSink

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

erroor.JPG (141K) Download Attachment

errormongo.JPG (25K) Download Attachment

errorMooo.JPG (16K) Download Attachment

Mongo.JPG (52K) Download Attachment

mongoS.JPG (73K) Download Attachment

mongoSS.JPG (60K) Download Attachment

r_khachatryan

Re: MongoSink

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 <[hidden email]> 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