Hi,
I was wondering if anyone have encountered the following error while running against n1ql:
on the dp4 the repl works well the same query
my code is
Statement statement = select("*").from(“default”).where(x("_identifier").eq(x(“placement”)));
Observable query = bucket.async().query(statement);
List toReturn = new LinkedList<>();
BlockingObservable asyncQueryRowBlockingObservable = query.doOnNext(result -> {
}).flatMap(AsyncQueryResult::rows).toBlocking();
toReturn.add(asyncQueryRowBlockingObservable.first());
The exception I get:
2015-01-21 18:07:05,638][WARN ][com.couchbase.client.core.endpoint.AbstractGenericHandler] [cb-dev/172.31.29.122:8093][QueryEndpoint]: Caught unknown exception: rx.subjects.ReplaySubject.onBackpressureBuffer()Lrx/Observable;
java.lang.NoSuchMethodError: rx.subjects.ReplaySubject.onBackpressureBuffer()Lrx/Observable;
at com.couchbase.client.core.endpoint.query.QueryHandler.handleGenericQueryResponse(QueryHandler.java:288) ~[core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.core.endpoint.query.QueryHandler.decodeResponse(QueryHandler.java:187) ~[core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.core.endpoint.query.QueryHandler.decodeResponse(QueryHandler.java:62) ~[core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.core.endpoint.AbstractGenericHandler.decode(AbstractGenericHandler.java:155) ~[core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.deps.io.netty.handler.codec.MessageToMessageCodec$2.decode(MessageToMessageCodec.java:81) ~[core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.deps.io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:89) ~[core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.deps.io.netty.handler.codec.MessageToMessageCodec.channelRead(MessageToMessageCodec.java:111) ~[core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:308) [core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:294) [core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.deps.io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:182) [core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.deps.io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:147) [core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:308) [core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:294) [core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.deps.io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:846) [core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.deps.io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:130) [core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511) [core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468) [core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382) [core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354) [core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.deps.io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) [core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.deps.io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137) [core-io-1.1.0-dp.jar:1.1.0-dp]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_25]
[2015-01-21 18:07:05,639][WARN ][com.couchbase.client.deps.io.netty.channel.DefaultChannelPipeline] An exceptionCaught() event was fired, and it reached at the tail of the pipeline. It usually means the last handler in the pipeline did not handle the exception.
java.lang.NoSuchMethodError: rx.subjects.ReplaySubject.onBackpressureBuffer()Lrx/Observable;
at com.couchbase.client.core.endpoint.query.QueryHandler.handleGenericQueryResponse(QueryHandler.java:288) ~[core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.core.endpoint.query.QueryHandler.decodeResponse(QueryHandler.java:187) ~[core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.core.endpoint.query.QueryHandler.decodeResponse(QueryHandler.java:62) ~[core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.core.endpoint.AbstractGenericHandler.decode(AbstractGenericHandler.java:155) ~[core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.deps.io.netty.handler.codec.MessageToMessageCodec$2.decode(MessageToMessageCodec.java:81) ~[core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.deps.io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:89) ~[core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.deps.io.netty.handler.codec.MessageToMessageCodec.channelRead(MessageToMessageCodec.java:111) ~[core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:308) [core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:294) [core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.deps.io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:182) [core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.deps.io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:147) [core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:308) [core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:294) [core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.deps.io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:846) [core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.deps.io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:130) [core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511) [core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468) [core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382) [core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354) [core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.deps.io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) [core-io-1.1.0-dp.jar:1.1.0-dp]
at com.couchbase.client.deps.io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137) [core-io-1.1.0-dp.jar:1.1.0-dp]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_25]
Any ideas