Search code examples
scalaapache-sparkspark-graphx

spark example wont compile

Trying to run one of apache sparks example codes (https://github.com/apache/spark/blob/master/examples/src/main/scala/org/apache/spark/examples/graphx/AggregateMessagesExample.scala) I get the following compile error

too many arguments for method sendToDst: (msg: (Int, Double))Unit
[error] Error occurred in an application involving default arguments.
[error]         triplet.sendToDst(1, triplet.srcAttr)
[error]                          ^
[error] one error found

But looking at the mehtods it seems to be correct. Not sure what is wrong here.

Solution

  • It looks like the method you are calling expects a single argument (a Tuple2) and you are passing in 2 arguments.

    Try

    triplet.sendToDst((1, triplet.srcAttr))