How to set Akka frame size

2013-12-24 Thread leosand...@gmail.com
Hi, everyone I have a question about the arg spark.akka.frameSize , it default value is 10m . I execute the JavaWordCount read data from hdfs , there is a 7G file . there is a oom error caused by some task result exceeded Akka frame size . but when I modify the arg 1G ,2G , 10G , it show me

Re: How to set Akka frame size

2013-12-24 Thread Aaron Davidson
The error you're receiving is because the Akka frame size must be a positive Java Integer, i.e., less than 2^31. However, the frame size is not intended to be nearly the size of the job memory -- it is the smallest unit of data transfer that Spark does. In this case, your task result size is