Re: Spark Job is stuck at SUBMITTED when set Driver Memory > Executor Memory

2017-06-04 Thread khwunchai jaengsawang
Hi Abdulfattah, Make sure you have enough resource available when submit the application, it seems like Spark is waiting to have enough resource. Best, Khwunchai Jaengsawang Email: khwuncha...@ku.th Mobile: +66 88 228 1715 LinkedIn <https://linkedin.com/in/khwunchai> |

Re: [RDDs and Dataframes] Equivalent expressions for RDD API

2017-03-05 Thread khwunchai jaengsawang
into PairRDD and use reduceByKey() Example: val pairs = data.map(row => (row(1), row(2)).reduceByKey(_+_) Best, Khwunchai Jaengsawang Email: khwuncha...@ku.th LinkedIn <https://linkedin.com/in/khwunchai> | Github <https://github.com/khwunchai> > On Mar 4, 2560 B

Handling Input Error in wholeTextFiles

2017-01-11 Thread khwunchai jaengsawang
r and the whole job is failed. I tried using flatMap with try statement, still failed. Is there any way to handle this? Regards, Khwunchai Jaengsawang Email: khwuncha...@ku.th Mobile: +66 88 228 1715 LinkedIn <https://linkedin.com/in/khwunchai> | Github <https://github.com/khwunch