Hi Sowen, the constructor just reads from the stream and stores only read data, but it's not keeping a reference to the stream itself, so I think this should work as it is.
Akshat, will try your suggestion in any case, thanks! -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/bug-with-MapPartitions-tp16689p16714.html Sent from the Apache Spark User List mailing list archive at Nabble.com. --------------------------------------------------------------------- To unsubscribe, e-mail: user-unsubscr...@spark.apache.org For additional commands, e-mail: user-h...@spark.apache.org
