Hi folks,
running into a pretty strange issue -- I have a ClassNotFound exception
from a closure?! My code looks like this:
val jRdd1 = table.map(cassRow=>{
val lst = List(cassRow.get[Option[Any]](0),cassRow.get[Option[Any]](1))
Row.fromSeq(lst)
})
println(s"This one worked .
Not sure why spark-submit isn't shipping your project jar (may be try with
--jars), You can do a sc.addJar(/path/to/your/project.jar) also, it should
solve it.
Thanks
Best Regards
On Wed, Jun 17, 2015 at 6:37 AM, Yana Kadiyska
wrote:
> Hi folks,
>
> running into a pretty strange issue -- I have
