Like this?
val krdd = testrdd.map(x => { try{var key = ""
val tmp_tocks = x.split(sep1)(0)(key,
x) }catch{ case e: Exception =>
println("Exception!! => " + e + "|||KS1 " + x)(null, x)
}})
Thanks
Best Regards
How can we catch exceptions that are thrown from custom RDDs or custom map
functions?
We have a custom RDD that is throwing an exception that we would like to
catch but the exception that is thrown back to the caller is a
*org.apache.spark.SparkException* that does not contain any useful
informat
