[info] Loading project definition from /Users/david.nault/repos/couchbase-spark-connector/project [info] Set current project to spark-connector (in build file:/Users/david.nault/repos/couchbase-spark-connector/) [warn] Credentials file /Users/david.nault/.ivy2/.credentials does not exist [info] FilterSpec: [info] The Filter [info] - should convert EqualTo [info] - should convert GreaterThan [info] - should convert GreaterThanOrEqual [info] - should convert LessThan [info] - should convert LessThanOrEqual [info] - should convert IsNull [info] - should convert IsNotNull [info] - should convert StringContains [info] - should convert StringStartsWith [info] - should convert StringEndsWith [info] - should escape . for StringStartsWith [info] - should escape * for StringStartsWith [info] - should escape . for StringEndsWith [info] - should escape * for StringEndsWith [info] - should convert In [info] - should convert And [info] - should convert Or [info] - should convert Not [info] - should parse paths in nested filter attributes [info] - should parse paths without nested filter attributes [info] - should parse deeply filter attributes [info] - should not parse text marked as verbatim [info] CouchbaseConnectionSpec: [info] A Connection [info] - should not be initialized more than once [info] - should maintain bucket references [info] CouchbaseConfigSpec: [info] A compat config containing nodes [info] - should merge with a regular nodes [info] - should accept compat bucket references in addition to regular ones [info] - should apply default settings [info] - should work only with com prefix settings [info] - should work only with spark prefix settings [info] - should apply default settings with empty list on com prefix [info] - should apply default settings with empty list on spark prefix [info] - should apply default retry values [info] - should set custom retry values on com prefix [info] - should set custom retry values on spark prefix [info] LazyIteratorSpec: [info] A LazyIterator [info] - should not create the delegated Iterator in the constructor [info] SubdocMutationAccessorSpec: [info] A SubdocMutationAccessor [info] - should upsert a path into a doc *** FAILED *** [info]  com.couchbase.client.java.error.DocumentDoesNotExistException: Document not found for subdoc API: doc [info]  at com.couchbase.client.java.subdoc.SubdocHelper.commonSubdocErrors(SubdocHelper.java:64) [info]  at com.couchbase.client.java.subdoc.AsyncMutateInBuilder$6.call(AsyncMutateInBuilder.java:1165) [info]  at com.couchbase.client.java.subdoc.AsyncMutateInBuilder$6.call(AsyncMutateInBuilder.java:1152) [info]  at com.couchbase.client.java.subdoc.AsyncMutateInBuilder$17.call(AsyncMutateInBuilder.java:1355) [info]  at com.couchbase.client.java.subdoc.AsyncMutateInBuilder$17.call(AsyncMutateInBuilder.java:1345) [info]  at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:69) [info]  at rx.observers.Subscribers$5.onNext(Subscribers.java:235) [info]  at rx.internal.operators.OnSubscribeDoOnEach$DoOnEachSubscriber.onNext(OnSubscribeDoOnEach.java:101) [info]  at rx.internal.producers.SingleProducer.request(SingleProducer.java:65) [info]  at rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126) [info]  ... [info]  Cause: rx.exceptions.OnErrorThrowable$OnNextValue: OnError while emitting onNext value: com.couchbase.client.core.message.kv.subdoc.simple.SimpleSubdocResponse.class [info]  at rx.exceptions.OnErrorThrowable.addValueAsLastCause(OnErrorThrowable.java:118) [info]  at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:73) [info]  at rx.observers.Subscribers$5.onNext(Subscribers.java:235) [info]  at rx.internal.operators.OnSubscribeDoOnEach$DoOnEachSubscriber.onNext(OnSubscribeDoOnEach.java:101) [info]  at rx.internal.producers.SingleProducer.request(SingleProducer.java:65) [info]  at rx.internal.producers.ProducerArbiter.setProducer(ProducerArbiter.java:126) [info]  at rx.internal.operators.OnSubscribeRedo$2$1.setProducer(OnSubscribeRedo.java:267) [info]  at rx.internal.operators.OnSubscribeMap$MapSubscriber.setProducer(OnSubscribeMap.java:102) [info]  at rx.Subscriber.setProducer(Subscriber.java:205) [info]  at rx.Subscriber.setProducer(Subscriber.java:205) [info]  ... [info] RDDFunctionsSpec: [info] A RDD [info] - should be created as a transformation [info] SparkContextFunctionsSpec: [info] A RDD [info] - should be created from Couchbase Document IDs [info] - should be created from a View [info] - should be created from a N1QL Query [info] CouchbaseDataFrameSpec: [info] The DataFrame API [info] - should infer the schemas *** FAILED *** [info]  org.apache.spark.SparkException: Job aborted due to stage failure: Task 0 in stage 1.0 failed 1 times, most recent failure: Lost task 0.0 in stage 1.0 (TID 1, localhost, executor driver): java.lang.RuntimeException: rx.exceptions.MissingBackpressureException [info]  at rx.exceptions.Exceptions.propagate(Exceptions.java:58) [info]  at rx.internal.operators.BlockingOperatorToIterator$SubscriberIterator.hasNext(BlockingOperatorToIterator.java:100) [info]  at scala.collection.convert.Wrappers$JIteratorWrapper.hasNext(Wrappers.scala:42) [info]  at com.couchbase.spark.internal.LazyIterator$$anon$1.hasNext(LazyIterator.scala:27) [info]  at scala.collection.Iterator$$anon$11.hasNext(Iterator.scala:408) [info]  at scala.collection.Iterator$$anon$12.hasNext(Iterator.scala:439) [info]  at scala.collection.Iterator$class.foreach(Iterator.scala:893) [info]  at scala.collection.AbstractIterator.foreach(Iterator.scala:1336) [info]  at scala.collection.TraversableOnce$class.foldLeft(TraversableOnce.scala:157) [info]  at scala.collection.AbstractIterator.foldLeft(Iterator.scala:1336) [info]  at scala.collection.TraversableOnce$class.fold(TraversableOnce.scala:212) [info]  at scala.collection.AbstractIterator.fold(Iterator.scala:1336) [info]  at org.apache.spark.rdd.RDD$$anonfun$fold$1$$anonfun$20.apply(RDD.scala:1087) [info]  at org.apache.spark.rdd.RDD$$anonfun$fold$1$$anonfun$20.apply(RDD.scala:1087) [info]  at org.apache.spark.SparkContext$$anonfun$32.apply(SparkContext.scala:1987) [info]  at org.apache.spark.SparkContext$$anonfun$32.apply(SparkContext.scala:1987) [info]  at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:87) [info]  at org.apache.spark.scheduler.Task.run(Task.scala:99) [info]  at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:322) [info]  at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [info]  at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [info]  at java.lang.Thread.run(Thread.java:748) [info] Caused by: rx.exceptions.MissingBackpressureException [info]  at rx.internal.util.RxRingBuffer.onNext(RxRingBuffer.java:325) [info]  at rx.internal.operators.OperatorMerge$MergeSubscriber.queueScalar(OperatorMerge.java:379) [info]  at rx.internal.operators.OperatorMerge$MergeSubscriber.tryEmit(OperatorMerge.java:361) [info]  at rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:846) [info]  at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77) [info]  at rx.observers.SafeSubscriber.onNext(SafeSubscriber.java:134) [info]  at rx.internal.operators.NotificationLite.accept(NotificationLite.java:135) [info]  at rx.internal.operators.BufferUntilSubscriber$OnSubscribeAction.call(BufferUntilSubscriber.java:108) [info]  at rx.internal.operators.BufferUntilSubscriber$OnSubscribeAction.call(BufferUntilSubscriber.java:80) [info]  at rx.Observable.subscribe(Observable.java:10442) [info]  at rx.Observable.subscribe(Observable.java:10409) [info]  at com.couchbase.client.core.utils.UnicastAutoReleaseSubject$OnSubscribeAction.call(UnicastAutoReleaseSubject.java:228) [info]  at com.couchbase.client.core.utils.UnicastAutoReleaseSubject$OnSubscribeAction.call(UnicastAutoReleaseSubject.java:207) [info]  at rx.Observable.unsafeSubscribe(Observable.java:10346) [info]  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48) [info]  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33) [info]  at rx.Observable.unsafeSubscribe(Observable.java:10346) [info]  at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:248) [info]  at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:148) [info]  at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77) [info]  at rx.internal.operators.OnSubscribeDoOnEach$DoOnEachSubscriber.onNext(OnSubscribeDoOnEach.java:101) [info]  at rx.internal.operators.OperatorMerge$MergeSubscriber.emitScalar(OperatorMerge.java:395) [info]  at rx.internal.operators.OperatorMerge$MergeSubscriber.tryEmit(OperatorMerge.java:355) [info]  at rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:846) [info]  at rx.internal.operators.OnSubscribeRedo$2$1.onNext(OnSubscribeRedo.java:244) [info]  at rx.internal.operators.OperatorMerge$MergeSubscriber.emitScalar(OperatorMerge.java:511) [info]  at rx.internal.operators.OperatorMerge$MergeSubscriber.tryEmit(OperatorMerge.java:466) [info]  at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:244) [info]  at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:148) [info]  at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77) [info]  at rx.observers.Subscribers$5.onNext(Subscribers.java:235) [info]  at rx.internal.producers.SingleProducer.request(SingleProducer.java:65) [info]  at rx.Subscriber.setProducer(Subscriber.java:211) [info]  at rx.internal.operators.OnSubscribeMap$MapSubscriber.setProducer(OnSubscribeMap.java:102) [info]  at rx.Subscriber.setProducer(Subscriber.java:205) [info]  at rx.subjects.AsyncSubject.onCompleted(AsyncSubject.java:103) [info]  at com.couchbase.client.core.endpoint.AbstractGenericHandler.completeResponse(AbstractGenericHandler.java:390) [info]  at com.couchbase.client.core.endpoint.AbstractGenericHandler.access$000(AbstractGenericHandler.java:72) [info]  at com.couchbase.client.core.endpoint.AbstractGenericHandler$1.call(AbstractGenericHandler.java:408) [info]  at rx.internal.schedulers.ScheduledAction.run(ScheduledAction.java:55) [info]  at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [info]  at java.util.concurrent.FutureTask.run(FutureTask.java:266) [info]  at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180) [info]  at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) [info]  ... 3 more [info]  [info] Driver stacktrace: [info]  at org.apache.spark.scheduler.DAGScheduler.org$apache$spark$scheduler$DAGScheduler$$failJobAndIndependentStages(DAGScheduler.scala:1435) [info]  at org.apache.spark.scheduler.DAGScheduler$$anonfun$abortStage$1.apply(DAGScheduler.scala:1423) [info]  at org.apache.spark.scheduler.DAGScheduler$$anonfun$abortStage$1.apply(DAGScheduler.scala:1422) [info]  at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59) [info]  at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:48) [info]  at org.apache.spark.scheduler.DAGScheduler.abortStage(DAGScheduler.scala:1422) [info]  at org.apache.spark.scheduler.DAGScheduler$$anonfun$handleTaskSetFailed$1.apply(DAGScheduler.scala:802) [info]  at org.apache.spark.scheduler.DAGScheduler$$anonfun$handleTaskSetFailed$1.apply(DAGScheduler.scala:802) [info]  at scala.Option.foreach(Option.scala:257) [info]  at org.apache.spark.scheduler.DAGScheduler.handleTaskSetFailed(DAGScheduler.scala:802) [info]  ... [info]  Cause: java.lang.RuntimeException: rx.exceptions.MissingBackpressureException [info]  at rx.exceptions.Exceptions.propagate(Exceptions.java:58) [info]  at rx.internal.operators.BlockingOperatorToIterator$SubscriberIterator.hasNext(BlockingOperatorToIterator.java:100) [info]  at scala.collection.convert.Wrappers$JIteratorWrapper.hasNext(Wrappers.scala:42) [info]  at com.couchbase.spark.internal.LazyIterator$$anon$1.hasNext(LazyIterator.scala:27) [info]  at scala.collection.Iterator$$anon$11.hasNext(Iterator.scala:408) [info]  at scala.collection.Iterator$$anon$12.hasNext(Iterator.scala:439) [info]  at scala.collection.Iterator$class.foreach(Iterator.scala:893) [info]  at scala.collection.AbstractIterator.foreach(Iterator.scala:1336) [info]  at scala.collection.TraversableOnce$class.foldLeft(TraversableOnce.scala:157) [info]  at scala.collection.AbstractIterator.foldLeft(Iterator.scala:1336) [info]  ... [info]  Cause: rx.exceptions.MissingBackpressureException: [info]  at rx.internal.util.RxRingBuffer.onNext(RxRingBuffer.java:325) [info]  at rx.internal.operators.OperatorMerge$MergeSubscriber.queueScalar(OperatorMerge.java:379) [info]  at rx.internal.operators.OperatorMerge$MergeSubscriber.tryEmit(OperatorMerge.java:361) [info]  at rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:846) [info]  at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77) [info]  at rx.observers.SafeSubscriber.onNext(SafeSubscriber.java:134) [info]  at rx.internal.operators.NotificationLite.accept(NotificationLite.java:135) [info]  at rx.internal.operators.BufferUntilSubscriber$OnSubscribeAction.call(BufferUntilSubscriber.java:108) [info]  at rx.internal.operators.BufferUntilSubscriber$OnSubscribeAction.call(BufferUntilSubscriber.java:80) [info]  at rx.Observable.subscribe(Observable.java:10442) [info]  ... [info] - should write and ignore [info] - should filter based on a function *** FAILED *** [info]  org.apache.spark.SparkException: Job aborted due to stage failure: Task 0 in stage 4.0 failed 1 times, most recent failure: Lost task 0.0 in stage 4.0 (TID 6, localhost, executor driver): java.lang.RuntimeException: rx.exceptions.MissingBackpressureException [info]  at rx.exceptions.Exceptions.propagate(Exceptions.java:58) [info]  at rx.internal.operators.BlockingOperatorToIterator$SubscriberIterator.hasNext(BlockingOperatorToIterator.java:100) [info]  at scala.collection.convert.Wrappers$JIteratorWrapper.hasNext(Wrappers.scala:42) [info]  at com.couchbase.spark.internal.LazyIterator$$anon$1.hasNext(LazyIterator.scala:27) [info]  at scala.collection.Iterator$$anon$11.hasNext(Iterator.scala:408) [info]  at scala.collection.Iterator$$anon$12.hasNext(Iterator.scala:439) [info]  at scala.collection.Iterator$class.foreach(Iterator.scala:893) [info]  at scala.collection.AbstractIterator.foreach(Iterator.scala:1336) [info]  at scala.collection.TraversableOnce$class.foldLeft(TraversableOnce.scala:157) [info]  at scala.collection.AbstractIterator.foldLeft(Iterator.scala:1336) [info]  at scala.collection.TraversableOnce$class.fold(TraversableOnce.scala:212) [info]  at scala.collection.AbstractIterator.fold(Iterator.scala:1336) [info]  at org.apache.spark.rdd.RDD$$anonfun$fold$1$$anonfun$20.apply(RDD.scala:1087) [info]  at org.apache.spark.rdd.RDD$$anonfun$fold$1$$anonfun$20.apply(RDD.scala:1087) [info]  at org.apache.spark.SparkContext$$anonfun$32.apply(SparkContext.scala:1987) [info]  at org.apache.spark.SparkContext$$anonfun$32.apply(SparkContext.scala:1987) [info]  at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:87) [info]  at org.apache.spark.scheduler.Task.run(Task.scala:99) [info]  at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:322) [info]  at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [info]  at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [info]  at java.lang.Thread.run(Thread.java:748) [info] Caused by: rx.exceptions.MissingBackpressureException [info]  at rx.internal.util.RxRingBuffer.onNext(RxRingBuffer.java:325) [info]  at rx.internal.operators.OperatorMerge$MergeSubscriber.queueScalar(OperatorMerge.java:379) [info]  at rx.internal.operators.OperatorMerge$MergeSubscriber.tryEmit(OperatorMerge.java:361) [info]  at rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:846) [info]  at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77) [info]  at rx.observers.SafeSubscriber.onNext(SafeSubscriber.java:134) [info]  at rx.internal.operators.NotificationLite.accept(NotificationLite.java:135) [info]  at rx.internal.operators.BufferUntilSubscriber$OnSubscribeAction.call(BufferUntilSubscriber.java:108) [info]  at rx.internal.operators.BufferUntilSubscriber$OnSubscribeAction.call(BufferUntilSubscriber.java:80) [info]  at rx.Observable.subscribe(Observable.java:10442) [info]  at rx.Observable.subscribe(Observable.java:10409) [info]  at com.couchbase.client.core.utils.UnicastAutoReleaseSubject$OnSubscribeAction.call(UnicastAutoReleaseSubject.java:228) [info]  at com.couchbase.client.core.utils.UnicastAutoReleaseSubject$OnSubscribeAction.call(UnicastAutoReleaseSubject.java:207) [info]  at rx.Observable.unsafeSubscribe(Observable.java:10346) [info]  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48) [info]  at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33) [info]  at rx.Observable.unsafeSubscribe(Observable.java:10346) [info]  at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:248) [info]  at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:148) [info]  at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77) [info]  at rx.internal.operators.OnSubscribeDoOnEach$DoOnEachSubscriber.onNext(OnSubscribeDoOnEach.java:101) [info]  at rx.internal.operators.OperatorMerge$MergeSubscriber.emitScalar(OperatorMerge.java:395) [info]  at rx.internal.operators.OperatorMerge$MergeSubscriber.tryEmit(OperatorMerge.java:355) [info]  at rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:846) [info]  at rx.internal.operators.OnSubscribeRedo$2$1.onNext(OnSubscribeRedo.java:244) [info]  at rx.internal.operators.OperatorMerge$MergeSubscriber.emitScalar(OperatorMerge.java:511) [info]  at rx.internal.operators.OperatorMerge$MergeSubscriber.tryEmit(OperatorMerge.java:466) [info]  at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:244) [info]  at rx.internal.operators.OperatorMerge$MergeSubscriber.onNext(OperatorMerge.java:148) [info]  at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77) [info]  at rx.observers.Subscribers$5.onNext(Subscribers.java:235) [info]  at rx.internal.producers.SingleProducer.request(SingleProducer.java:65) [info]  at rx.Subscriber.setProducer(Subscriber.java:211) [info]  at rx.internal.operators.OnSubscribeMap$MapSubscriber.setProducer(OnSubscribeMap.java:102) [info]  at rx.Subscriber.setProducer(Subscriber.java:205) [info]  at rx.subjects.AsyncSubject.onCompleted(AsyncSubject.java:103) [info]  at com.couchbase.client.core.endpoint.AbstractGenericHandler.completeResponse(AbstractGenericHandler.java:390) [info]  at com.couchbase.client.core.endpoint.AbstractGenericHandler.access$000(AbstractGenericHandler.java:72) [info]  at com.couchbase.client.core.endpoint.AbstractGenericHandler$1.call(AbstractGenericHandler.java:408) [info]  at rx.internal.schedulers.ScheduledAction.run(ScheduledAction.java:55) [info]  at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [info]  at java.util.concurrent.FutureTask.run(FutureTask.java:266) [info]  at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180) [info]  at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) [info]  ... 3 more [info]  [info] Driver stacktrace: [info]  at org.apache.spark.scheduler.DAGScheduler.org$apache$spark$scheduler$DAGScheduler$$failJobAndIndependentStages(DAGScheduler.scala:1435) [info]  at org.apache.spark.scheduler.DAGScheduler$$anonfun$abortStage$1.apply(DAGScheduler.scala:1423) [info]  at org.apache.spark.scheduler.DAGScheduler$$anonfun$abortStage$1.apply(DAGScheduler.scala:1422) [info]  at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59) [info]  at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:48) [info]  at org.apache.spark.scheduler.DAGScheduler.abortStage(DAGScheduler.scala:1422) [info]  at org.apache.spark.scheduler.DAGScheduler$$anonfun$handleTaskSetFailed$1.apply(DAGScheduler.scala:802) [info]  at org.apache.spark.scheduler.DAGScheduler$$anonfun$handleTaskSetFailed$1.apply(DAGScheduler.scala:802) [info]  at scala.Option.foreach(Option.scala:257) [info]  at org.apache.spark.scheduler.DAGScheduler.handleTaskSetFailed(DAGScheduler.scala:802) [info]  ... [info]  Cause: java.lang.RuntimeException: rx.exceptions.MissingBackpressureException [info]  at rx.exceptions.Exceptions.propagate(Exceptions.java:58) [info]  at rx.internal.operators.BlockingOperatorToIterator$SubscriberIterator.hasNext(BlockingOperatorToIterator.java:100) [info]  at scala.collection.convert.Wrappers$JIteratorWrapper.hasNext(Wrappers.scala:42) [info]  at com.couchbase.spark.internal.LazyIterator$$anon$1.hasNext(LazyIterator.scala:27) [info]  at scala.collection.Iterator$$anon$11.hasNext(Iterator.scala:408) [info]  at scala.collection.Iterator$$anon$12.hasNext(Iterator.scala:439) [info]  at scala.collection.Iterator$class.foreach(Iterator.scala:893) [info]  at scala.collection.AbstractIterator.foreach(Iterator.scala:1336) [info]  at scala.collection.TraversableOnce$class.foldLeft(TraversableOnce.scala:157) [info]  at scala.collection.AbstractIterator.foldLeft(Iterator.scala:1336) [info]  ... [info]  Cause: rx.exceptions.MissingBackpressureException: [info]  at rx.internal.util.RxRingBuffer.onNext(RxRingBuffer.java:325) [info]  at rx.internal.operators.OperatorMerge$MergeSubscriber.queueScalar(OperatorMerge.java:379) [info]  at rx.internal.operators.OperatorMerge$MergeSubscriber.tryEmit(OperatorMerge.java:361) [info]  at rx.internal.operators.OperatorMerge$InnerSubscriber.onNext(OperatorMerge.java:846) [info]  at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77) [info]  at rx.observers.SafeSubscriber.onNext(SafeSubscriber.java:134) [info]  at rx.internal.operators.NotificationLite.accept(NotificationLite.java:135) [info]  at rx.internal.operators.BufferUntilSubscriber$OnSubscribeAction.call(BufferUntilSubscriber.java:108) [info]  at rx.internal.operators.BufferUntilSubscriber$OnSubscribeAction.call(BufferUntilSubscriber.java:80) [info]  at rx.Observable.subscribe(Observable.java:10442) [info]  ... [info] Run completed in 7 seconds, 570 milliseconds. [info] Total number of tests run: 43 [info] Suites: completed 8, aborted 0 [info] Tests: succeeded 40, failed 3, canceled 0, ignored 0, pending 0 [info] *** 3 TESTS FAILED *** [error] Failed tests: [error]  com.couchbase.spark.connection.SubdocMutationAccessorSpec [error]  com.couchbase.spark.sql.CouchbaseDataFrameSpec [error] (test:test) sbt.TestsFailedException: Tests unsuccessful [error] Total time: 8 s, completed Jul 27, 2017 4:42:14 PM