Hello Community,

I'm running Spark on a single Server in a stand-alone mode . The Server has
*two cores*  and so while initializing the SparkContext object, I used

*var sc = new SparkContext("local[2]", "MyApp", SPARK_HOME)*

 [ As per this
http://spark.incubator.apache.org/docs/0.6.0/scala-programming-guide.html#master-urls
]

But, the program while processing files of size more than 60MB hangs. This
without emitting any error message or anything(I have my Heap size
increased to large size). Also, when I checked *the _temporary directory * in
output location, I noticed that the program has stopped doing any further
processing/parsing of my input directory.

Any ideas on why it happens when I use "local[2]" ?

Regards,

Ramkumar Chokkalingam ,
University of Washington.
LinkedIn <http://www.linkedin.com/in/mynameisram>

Reply via email to