Error QueryRequest SHUTDOWN with Java SDK

Han_Chris1 · May 12, 2021, 8:38am

Hi All,

I’m using Couchbase 6.5.1 and Java Client SDK 3.1.0
I’m building REST API using qurakus and sometimes get below error :

com.couchbase.client.core.error.RequestCanceledException: QueryRequest, Reason: SHUTDOWN {“cancelled”:true,“completed”:true,“coreId”:“0x8fd1e84a00000477”,“idempotent”: false,“reason”:“SHUTDOWN”,“requestId”:280866,“requestType”:“QueryRequest”,“retried”:0,“service”:{“operationId”:“d10d829e-d6ab-496a-9791-4a18a373562a”,“statement”:“SELECT xxxxxxxx”,“type”:“query”}, “timeoutMs”:300000,“timings”:{“totalMicros”:149}}

After get this error, my app can not reconnect to couchbase.

What’s the reason of this error?
How to make it reconnect automatically?

Han_Chris1 · May 17, 2021, 2:32am

Any expert here?
I saw this error log before getting that error message :

2021-05-15 03:03:10,034 ERROR [rea.cor.pub.Operators] (cb-io-kv-5-2) Operator called default onErrorDropped: com.couchbase.client.core.error.RequestCanceledException: CarrierGlobalConfigRequest, Reason: NO_MORE_RETRIES (CHANNEL_CLOSED_WHILE_IN_FLIGHT) {“cancelled”:true,“completed”:true,“coreId”:“0xfe397c1700000220”,“idempotent”:true,“lastChannelId”:“FE397C1700000220/00000000C9C70D6E”,“lastDispatchedFrom”:“172.18.0.5:53364”,“lastDispatchedTo”:“VIDDCLXPCUVAP22.pru.intranet.asia:11210”,“reason”:“NO_MORE_RETRIES (CHANNEL_CLOSED_WHILE_IN_FLIGHT)”,“requestId”:134041,“requestType”:“CarrierGlobalConfigRequest”,“retried”:0,“service”:{“opaque”:“0x279a8”,“target”:“VIDDCLXPCUVAP22.pru.intranet.asia”,“type”:“kv”},“timeoutMs”:2500}
at com.couchbase.client.core.msg.BaseRequest.cancel(BaseRequest.java:169)
at com.couchbase.client.core.retry.RetryOrchestrator.lambda$maybeRetry$0(RetryOrchestrator.java:79)
at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
at java.base/java.util.concurrent.CompletableFuture.uniWhenCompleteStage(CompletableFuture.java:883)
at java.base/java.util.concurrent.CompletableFuture.whenComplete(CompletableFuture.java:2251)
at com.couchbase.client.core.retry.RetryOrchestrator.maybeRetry(RetryOrchestrator.java:62)
at com.couchbase.client.core.io.netty.kv.KeyValueMessageHandler.channelInactive(KeyValueMessageHandler.java:260)
at com.couchbase.client.core.deps.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:262)
at com.couchbase.client.core.deps.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:248)
at com.couchbase.client.core.deps.io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:241)
at com.couchbase.client.core.deps.io.netty.handler.codec.ByteToMessageDecoder.channelInputClosed(ByteToMessageDecoder.java:389)
at com.couchbase.client.core.deps.io.netty.handler.codec.ByteToMessageDecoder.channelInactive(ByteToMessageDecoder.java:354)
at com.couchbase.client.core.deps.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:262)
at com.couchbase.client.core.deps.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:248)
at com.couchbase.client.core.deps.io.netty.channel.AbstractChannelHandlerContext.fireChannelInactive(AbstractChannelHandlerContext.java:241)
at com.couchbase.client.core.deps.io.netty.channel.DefaultChannelPipeline$HeadContext.channelInactive(DefaultChannelPipeline.java:1405)
at com.couchbase.client.core.deps.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:262)
at com.couchbase.client.core.deps.io.netty.channel.AbstractChannelHandlerContext.invokeChannelInactive(AbstractChannelHandlerContext.java:248)
at com.couchbase.client.core.deps.io.netty.channel.DefaultChannelPipeline.fireChannelInactive(DefaultChannelPipeline.java:901)
at com.couchbase.client.core.deps.io.netty.channel.AbstractChannel$AbstractUnsafe$8.run(AbstractChannel.java:819)
at com.couchbase.client.core.deps.io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:164)
at com.couchbase.client.core.deps.io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472)
at com.couchbase.client.core.deps.io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:384)
at com.couchbase.client.core.deps.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
at com.couchbase.client.core.deps.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
at com.couchbase.client.core.deps.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.base/java.lang.Thread.run(Thread.java:829)

daschl · May 17, 2021, 5:33am

@Han_Chris1 you shutdown the SDK and after that you performed an operation on it - this is not allowed.