search

ReactiveCouchbase / ReactiveCouchbase-core

Core library for ReactiveCouchbase
Apache License 2.0
64 stars 28 forks source link

java.lang.UnsupportedOperationException: Flush has no OperationStatus. #49

Open alexanderjarvis opened 9 years ago

alexanderjarvis commented 9 years ago

Before some of my integration tests I run the following:

def dropAll = {
    Await.ready(PlayCouchbase.bucket("default").flush(), timeout)
}

But it spews a warning:

2014-11-28 12:14:34.440 WARN com.couchbase.client.CouchbaseClient$19:  Exception thrown wile executing org.reactivecouchbase.client.CouchbaseFutures$$anon$6.operationComplete()
java.lang.UnsupportedOperationException: Flush has no OperationStatus.
    at com.couchbase.client.CouchbaseClient$19.getStatus(CouchbaseClient.java:1967)
    at org.reactivecouchbase.client.CouchbaseFutures$.org$reactivecouchbase$client$CouchbaseFutures$$complete$7(CouchbaseFutures.scala:315)
    at org.reactivecouchbase.client.CouchbaseFutures$$anon$6.onComplete(CouchbaseFutures.scala:327)
    at org.reactivecouchbase.client.CouchbaseFutures$$anon$6.onComplete(CouchbaseFutures.scala:326)
    at net.spy.memcached.internal.AbstractListenableFuture$1.run(AbstractListenableFuture.java:117)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
    at java.util.concurrent.FutureTask.run(FutureTask.java:262)
    at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:41)
    at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:393)
    at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
    at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
    at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
    at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)

It looks like the client is trying to get a status for an operation that doesn't have one?