Spark Executors fail with exception

This is my code. I am saving the RDD to a bucket. The data upsert to the bucket finishes fine, but the executors fail with the below exception. Did any body else face the same issue? Any help is greatly appreciated.

val sparkConf = new SparkConf().setAppName(appName)
.set(“com.couchbase.nodes”, couchbaseHost)
.set(“com.couchbase.bucket.”+couchbaseBucket, couchbasePassword)
.set(“com.couchbase.kvTimeout”, “10000”)
.set(“com.couchbase.connectTimeout”, “30000”)
.set(“com.couchbase.socketConnect”, “10000”)

val sc = new SparkContext(sparkConf)
val sqlContext = new SQLContext(sc)
val hiveContext = new HiveContext(sc)

val hotCar=hiveContext.sql(“SELECT * FROM insight_dev.hot_car_zip”)

val mapped=hotCar.map(x=> ((x.getString(0),x.getString(1),x.getString(2),x.getString(3),x.getString(4),x.getTimestamp(5).toString,x.getString(6),x.getTimestamp(7).toString),HotCarListing.Listing(x.getString(8),x.getString(9),x.getString(10),x.getString(11),x.getString(12),x.getTimestamp(13).toString,x.getString(14))))

val savingData=mapped.groupByKey().map(x => createHotCarsJson(x._1._1,x._1._2,x._1._3,x._1._4,x._1._5,x._1._6,x._1._7,x._1._8,x._2))

savingData.saveToCouchbase()

def createHotCarsJson(id: String, originalZipCode: String, radius: String, docType: String, createUserNm: String, createDate: String, updateUserNm: String, updateDateUTC: String, listings: Iterable[HotCarListing.Listing]): RawJsonDocument =
{
val hotCars=listings.toArray
val documentType=“hotCarsByZip”
val payload=HotCarListing.getHotCarsByZipJSON(HotCarListing.HotCarsByZip(id,documentType,createUserNm,System.currentTimeMillis(),originalZipCode,radius,updateUserNm,System.currentTimeMillis(),hotCars))

val key=documentType+"::"+id
val rawJson=RawJsonDocument.create(key,TimeUnit.DAYS.toSeconds(7).toInt,payload)

rawJson

}

java.lang.IllegalStateException: Fatal Exception thrown on Scheduler.Worker thread.
at rx.internal.schedulers.ScheduledAction.run(ScheduledAction.java:62)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.AbstractMethodError
at org.apache.spark.Logging$class.log(Logging.scala:50)
at com.couchbase.spark.DocumentRDDFunctions.log(DocumentRDDFunctions.scala:34)
at org.apache.spark.Logging$class.logInfo(Logging.scala:58)
at com.couchbase.spark.DocumentRDDFunctions.logInfo(DocumentRDDFunctions.scala:34)
at com.couchbase.spark.DocumentRDDFunctions$$anon$1.call(DocumentRDDFunctions.scala:83)
at com.couchbase.spark.DocumentRDDFunctions$$anon$1.call(DocumentRDDFunctions.scala:81)
at com.couchbase.client.java.util.retry.RetryWithDelayHandler.call(RetryWithDelayHandler.java:109)
at com.couchbase.client.java.util.retry.RetryWithDelayHandler.call(RetryWithDelayHandler.java:42)
at rx.internal.operators.OperatorMap$MapSubscriber.onNext(OperatorMap.java:66)
at rx.internal.operators.OperatorZip$Zip.tick(OperatorZip.java:264)
at rx.internal.operators.OperatorZip$Zip$InnerSubscriber.onNext(OperatorZip.java:335)
at rx.internal.operators.OperatorMap$MapSubscriber.onNext(OperatorMap.java:74)
at rx.internal.operators.OnSubscribeRedo$3$1.onNext(OnSubscribeRedo.java:307)
at rx.internal.operators.OnSubscribeRedo$3$1.onNext(OnSubscribeRedo.java:289)
at rx.internal.operators.NotificationLite.accept(NotificationLite.java:150)
at rx.subjects.SubjectSubscriptionManager$SubjectObserver.emitNext(SubjectSubscriptionManager.java:253)
at rx.subjects.BehaviorSubject.onNext(BehaviorSubject.java:160)
at rx.internal.operators.OnSubscribeRedo$2$1.onError(OnSubscribeRedo.java:242)
at rx.internal.operators.OperatorMap$MapSubscriber.onError(OperatorMap.java:85)
at rx.observers.Subscribers$5.onError(Subscribers.java:224)
at rx.subjects.SubjectSubscriptionManager$SubjectObserver.onError(SubjectSubscriptionManager.java:227)
at rx.subjects.AsyncSubject.onError(AsyncSubject.java:118)
at com.couchbase.client.core.CouchbaseCore.send(CouchbaseCore.java:212)
at com.couchbase.client.core.ResponseHandler$3.call(ResponseHandler.java:189)
at rx.internal.schedulers.ScheduledAction.run(ScheduledAction.java:55)
… 7 more