Re: scala version of flink mongodb example

Posted by alex.decastro on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/scala-version-of-flink-mongodb-example-tp8971p11489.html

Hi there, treading in the thread,

do you know how to add authentication options to mongo here?

I'm trying to do

hdIf.getJobConf.set("user", s"$USER")
hdIf.getJobConf.set("password", s"$PWD")

but I can't find any documentation to support it.

Any pointers?

Many thanks,
Alex