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 <aissaelaff...@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 >
