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.