> > >
> > > ```
> > >
> > >
> > >
> > > Could you please clarify what methods does the
> MongoDeserializationSchema
> > > class overrides, like `deserialize(BsonDocument)` method, or
> > > `deserialize(BsonDocument, Collecto
he
> > MongoDeserializationSchema
> > class overrides, like `deserialize(BsonDocument)` method, or
> > `deserialize(BsonDocument, Collector)`, too?
> >
> >
> >
> > Regards,
> >
> > Xiqian
> >
> >
> >
> > *De : *Sachin Mitta
s,
>
> Xiqian
>
>
>
> *De : *Sachin Mittal
> *Date : *lundi, 5 août 2024 à 19:59
> *À : *user@flink.apache.org
> *Objet : *How can I debug Assigned key must not be null error when
> reading from Mongodb source
>
> Hi,
>
> I am using mongodb connector provided in he
(BsonDocument, Collector)`, too?
Regards,
Xiqian
De : Sachin Mittal
Date : lundi, 5 août 2024 à 19:59
À : user@flink.apache.org
Objet : How can I debug Assigned key must not be null error when reading from
Mongodb source
Hi,
I am using mongodb connector provided in here:
https
Hi,
I am using mongodb connector provided in here:
https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/connectors/datastream/mongodb/
I am instantiating it pretty much in the recommended way:
MongoSource source =
MongoSource.builder()
.setUri("...")
.setDatabase("...")
.setCollection(
