Oh, looks like the Scala Map isn't serializable. I switched the code to use java.util.HashMap, which should work.
Ankur <http://www.ankurdave.com/> On Mon, May 26, 2014 at 3:21 PM, daze5112 <david.zeel...@ato.gov.au> wrote: > Excellent thanks Ankur, looks like what im looking for Only one problem > the > line > > val dists = initDists.pregel[DistanceMap](Map())(vprog, sendMsg, mergeMsg) > > produces an error > Job aborted: Task 268.0:5 had a not serializable result: > java.io.NotSerializableException: > scala.collection.immutable.MapLike$$anon$2 > > any ideas? > > thanks > > > > -- > View this message in context: > http://apache-spark-user-list.1001560.n3.nabble.com/counting-degrees-graphx-tp6370p6405.html > Sent from the Apache Spark User List mailing list archive at Nabble.com. >
