Hi, I am writing an app in Spark ( 1.6.1 ) in which I am using an accumulator. My accumulator is simply counting rows: acc += 1. My test processes 4 files each with 4 rows however the value of the accumulator in the end is not 16 and even worse is inconsistent between runs.
Are accumulators not to be used in LocalMode?, Is it a known issue? Many thanks, Harel. -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/Using-accumulators-in-Local-mode-for-testing-tp27321.html Sent from the Apache Spark User List mailing list archive at Nabble.com. --------------------------------------------------------------------- To unsubscribe e-mail: user-unsubscr...@spark.apache.org
