Does anyone have any answer. How does the state distribution happen among multiple nodes. I have seen that in "mapwithState" based workflow the streaming job simply hangs when the node containing all states dies because of OOM.
..Manas -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/How-State-of-mapWithState-is-distributed-on-nodes-tp27593p28313.html Sent from the Apache Spark User List mailing list archive at Nabble.com. --------------------------------------------------------------------- To unsubscribe e-mail: user-unsubscr...@spark.apache.org
