Thank you Ankur for your help and support!!! On Tue, Nov 4, 2014 at 5:24 AM, Ankur Dave <ankurd...@gmail.com> wrote:
> The NullPointerException seems to be because edge.dstAttr is null, which > might be due to SPARK-3936 > <https://issues.apache.org/jira/browse/SPARK-3936>. Until that's fixed, I > edited the Gist with a workaround. Does that fix the problem? > > Ankur <http://www.ankurdave.com/> > > On Mon, Nov 3, 2014 at 12:23 AM, Madabhattula Rajesh Kumar < > mrajaf...@gmail.com> wrote: > >> Hi All, >> >> I'm trying to understand below link example program. When I run this >> program, I'm getting "*java.lang.NullPointerException*" at below >> highlighted line. >> >> *https://gist.github.com/ankurdave/4a17596669b36be06100 >> <https://gist.github.com/ankurdave/4a17596669b36be06100>* >> >> val updatedDists = edge.srcAttr.filter { >> case (source, dist) => >> *val existingDist = edge.dstAttr.getOrElse(source, Int.MaxValue) * >> existingDist > dist + 1 >> }.mapValues(_ + 1).map(identity) >> >> Could you please help me to resolve this issue. >> >> Regards, >> Rajesh >> > >
