Re: Exception Handling : Spark Streaming

2015-09-11 Thread Ted Yu
gt; > wordCountPair.foreachRDD(rdd => > rdd.saveToCassandra("nexti","direct_api_test",AllColumns)) > > ssc.start() > ssc.awaitTermination() > } > catch { > case ex: Exception =>{ > println(">>>>>>>

Exception Handling : Spark Streaming

2015-09-11 Thread Samya
t;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 your in