!!!
- Sam
From: Ted Yu [mailto:yuzhih...@gmail.com]
Sent: Friday, September 11, 2015 8:05 PM
To: Samya MAITI
Cc: user
Subject: Re: Exception Handling : Spark Streaming
Was your intention that exception from rdd.saveToCassandra() be caught ?
In that case you can place try / catch around that call
,"direct_api_test",AllColumns))
ssc.start()
ssc.awaitTermination()
}
catch {
case ex: Exception =>{
println(">>>>>>>> Exception UNKNOWN Only.")
}
}
}
I am sure that missing out on something, please provide yo
tPair.foreachRDD(rdd =>
> rdd.saveToCassandra("nexti","direct_api_test",AllColumns))
>
> ssc.start()
> ssc.awaitTermination()
> }
> catch {
> case ex: Exception =>{
> println(">>>>>>>> Exception UNKNOWN Only
