spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Madabhattula Rajesh Kumar <mrajaf...@gmail.com>
Subject To find distances to reachable source vertices using GraphX
Date Mon, 03 Nov 2014 08:23:37 GMT
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

Mime
View raw message