KafkaUtils.createDirectStream() with kafka topic expanded

2016-09-13 Thread vinay gupta
Hi we are using the following version of KafkaUtils.createDirectStream() from spark 1.5.0 createDirectStream(JavaStreamingContext jssc, Class keyClass, Class valueClass,

spark-streaming with checkpointing: error with sparkOnHBase lib

2016-01-22 Thread vinay gupta
Hi,  I have a spark-streaming application which uses sparkOnHBase lib to do streamBulkPut() Without checkpointing everything works fine.. But recently upon enabling checkpointing I got thefollowing exception -  16/01/22 01:32:35 ERROR executor.Executor: Exception in task 0.0 in stage 39.0 (TID