Please send your call stack with the full description of the exception .
> On 10 Dec 2015, at 12:10, Бобров Виктор <ma...@bk.ru> wrote: > > Hi, I can’t filter my rdd. > > def filter1(tp: ((Array[String], Int), (Array[String], Int))): Boolean= { > tp._1._2 > tp._2._2 > } > val mail_rdd = sc.parallelize(A.toSeq).cache() > val step1 = mail_rdd.cartesian(mail_rdd) > val step2 = step1.filter(filter1) > > Get error “Class not found”. What I’m doing wrong ? Thanks for help. > > >