OutOfMemorryError after chaning to .persist(StorageLevel.MEMORY_ONLY_SER)

2016-03-03 Thread Jake Yoon
Hi, Spark users. I am getting the following OutOfMemoryError: Java heap space after changing to StorageLevel.MEMORY_ONLY_SER. MEMORY_AND_DISK_SER also throws the same error. I thought DISK option should put unfitting blocks to the disk. What could cause the OOM in such situation? Is there any

Unshaded google guava classes in spark-network-common jar

2016-01-11 Thread Jake Yoon
I found an unshaded google guava classes used internally in spark-network-common while working with ElasticSearch. Following link discusses about duplicate dependencies conflict cause by guava classes and how I solved the build conflict issue.

Occasionally getting RpcTimeoutException

2015-11-01 Thread Jake Yoon
Hi Sparkers. I am very new to Spark, and I am occasionally getting RpCTimeoutException with the following error. 15/11/01 22:19:46 WARN HeartbeatReceiver: Removing executor 0 with no > recent heartbeats: 321792 ms exceeds timeout 30 ms > 15/11/01 22:19:46 ERROR TaskSchedulerImpl: Lost