Re: Error in running JavaALSExample example from spark examples

2016-07-22 Thread VG
Using 2.0.0-preview using maven So all dependencies should be correct I guess org.apache.spark spark-core_2.11 2.0.0-preview provided I see in maven dependencies that this brings in scala-reflect-2.11.4 scala-compiler-2.11.0 and so on On Fri, Jul 22, 2016 at 11:04 PM, Aaron Ilovici wrote:

Error in running JavaALSExample example from spark examples

2016-07-22 Thread VG
solve this VG

Re: Dataset , RDD zipWithIndex -- How to use as a map .

2016-07-22 Thread VG
Hi All, Any suggestions for this Regards, VG On Fri, Jul 22, 2016 at 6:40 PM, VG wrote: > Hi All, > > I am really confused how to proceed further. Please help. > > I have a dataset created as follows: > Dataset b = sqlContext.sql("SELECT bid, name FROM business")

Re: ml ALS.fit(..) issue

2016-07-22 Thread VG
Dev team, Can someone please help me here. -VG On Fri, Jul 22, 2016 at 8:30 PM, VG wrote: > Can someone please help here. > > I tried both scala 2.10 and 2.11 on the system > > > > On Fri, Jul 22, 2016 at 7:59 PM, VG wrote: > >> I am using version 2.0.0-prev

ERROR RetryingBlockFetcher: Exception while beginning fetch of 1 outstanding blocks

2016-06-15 Thread VG
I have a very simple driver which loads a textFile and filters a sub-string from each line in the textfile. When the collect action is executed , I am getting an exception. (The file is only 90 MB - so I am confused what is going on..) I am running on a local standalone cluster 16/06/15 19:45:22