You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by "alex.decastro" <al...@lab49.com> on 2017/02/07 15:54:41 UTC

Re: scala version of flink mongodb example

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





--
View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/scala-version-of-flink-mongodb-example-tp8971p11489.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.