Is there a way to specify query timeout in Couchbase spark connector?
scala> val custVals = customfield.as(“cf”).join(customfieldvalue.as(“cv”), "cf.id" === “cv.issue”)
custVals: org.apache.spark.sql.DataFrame = [META_ID: string, cfname: string … 15 more fields]
scala> custVals.count()
com.couchbase.client.java.error.QueryExecutionException: Timeout 1m15s exceeded
at com.couchbase.spark.connection.QueryAccessor$$anonfun$compute$1$$anonfun$apply$2$$anonfun$4.apply(QueryAccessor.scala:56)
at com.couchbase.spark.connection.QueryAccessor$$anonfun$compute$1$$anonfun$apply$2$$anonfun$4.apply(QueryAccessor.scala:53)
at rx.lang.scala.Observable$$anon$32.call(Observable.scala:1324)
at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:69)
at rx.internal.operators.OnSubscribeMap$MapSubscriber.onNext(OnSubscribeMap.java:77)
at rx.internal.operators.NotificationLite.accept(NotificationLite.java:135)
at rx.internal.operators.OperatorOnBackpressureBuffer$BufferSubscriber.accept(OperatorOnBackpressureBuffer.java:156)
at rx.internal.util.BackpressureDrainManager.drain(BackpressureDrainManager.java:198)
at rx.internal.operators.OperatorOnBackpressureBuffer$BufferSubscriber.onNext(OperatorOnBackpressureBuffer.java:151)
at rx.observers.SafeSubscriber.onNext(SafeSubscriber.java:134)
at rx.internal.operators.NotificationLite.accept(NotificationLite.java:135)
at rx.internal.operators.BufferUntilSubscriber.emit(BufferUntilSubscriber.java:146)