java client 3.1.5
couchbase server 7.0 beta .
imported travel-sample bucket and inventory scope and collections .
When try to insert json to hotel collection getting below exception,
Caused by: com.couchbase.client.core.error.AmbiguousTimeoutException: InsertRequest, Reason: TIMEOUT {“cancelled”:true,“completed”:true,“coreId”:“0xa3fa806900000001”,“idempotent”:false,“lastChannelId”:“A3FA806900000001/000000002450FD2D”,“lastDispatchedFrom”:“127.0.0.1:61932”,“lastDispatchedTo”:“localhost:11210”,“reason”:“TIMEOUT”,“requestId”:110,“requestType”:“InsertRequest”,“retried”:19,“retryReasons”:[“COLLECTION_NOT_FOUND”],“service”:{“bucket”:“travel-sample”,“collection”:“hotel”,“documentId”:“hote-2001”,“opaque”:“0x81”,“scope”:“inventory”,“type”:“kv”},“timeoutMs”:5000,“timings”:{“encodingMicros”:4181,“totalMicros”:5009266}}
at com.couchbase.client.core.msg.BaseRequest.cancel(BaseRequest.java:170)
at com.couchbase.client.core.Timer.lambda$register$2(Timer.java:157)
at com.couchbase.client.core.deps.io.netty.util.HashedWheelTimer$HashedWheelTimeout.expire(HashedWheelTimer.java:672)
at com.couchbase.client.core.deps.io.netty.util.HashedWheelTimer$HashedWheelBucket.expireTimeouts(HashedWheelTimer.java:747)
at com.couchbase.client.core.deps.io.netty.util.HashedWheelTimer$Worker.run(HashedWheelTimer.java:472)
at com.couchbase.client.core.deps.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.base/java.lang.Thread.run(Thread.java:834)
Suppressed: java.lang.Exception: #block terminated with an error
at reactor.core.publisher.BlockingSingleSubscriber.blockingGet(BlockingSingleSubscriber.java:99)
at reactor.core.publisher.Mono.block(Mono.java:1703)
Tried printing collections
ReactiveCollectionManager mgr = reactiveBucket.collections();
-
mgr.getAllScopes().toIterable()*
-
.forEach(ss -> ss.collections().stream().forEach(cs -> System.out.println(cs.name())));*
below collections are getting printed
hotel
landmark
route
airline
airport
- if try to insert into _default collection ,its working fine . json doc inserted successfully with _default scope and _default collection .
below code used to insert json doc:
ReactiveCollection reactiveCollection = reactiveBucket.scope(scopeName).collection(collection);
JsonObject content = …
reactiveCollection.insert(docId, content).block()