Re: java client: overload leads to BlockingOperationException
Hi Henning,
The best place to continue discussion would be to file an issue in
GitHub. This sounds like a bug or at least a place for improvement.
https://github.com/basho/riak-java-client/issues
> How many active, busy connections does Riak KV support?
You're correct that "it depends" is the right answer. In doing some
benchmarks with the .NET client, I found that there was little benefit
to the maximum number of connections exceeding the ring size in the
cluster. This is probably specific to the benchmarks I was doing at
the time, too. The best option is always to simulate your workload,
tweak settings, and benchmark.
--
Luke Bakken
Engineer
lbak...@basho.com
On Wed, Jul 13, 2016 at 7:03 AM, Henning Verbeek wrote:
> I'm still struggling with a BlockingOperationException thrown by
> riak-java-client 2.0.6, which occurs when I put heavy load on Riak KV.
> Since https://github.com/basho/riak-java-client/issues/523 is fixed,
> this happens only in - what I assume is - an overload-scenario.
>
> The exception:
>
> 2016-07-13 14:41:12.789 localhost [nioEventLoopGroup-2-2] ERROR
> com.basho.riak.client.core.RiakNode - Operation onException() channel:
> id:237445453 localhost:8087 {}
> io.netty.util.concurrent.BlockingOperationException:
> DefaultChannelPromise@77ccd827(incomplete)
> at
> io.netty.util.concurrent.DefaultPromise.checkDeadLock(DefaultPromise.java:390)
> at
> io.netty.channel.DefaultChannelPromise.checkDeadLock(DefaultChannelPromise.java:157)
> at
> io.netty.util.concurrent.DefaultPromise.await(DefaultPromise.java:251)
> at
> io.netty.channel.DefaultChannelPromise.await(DefaultChannelPromise.java:129)
> at
> io.netty.channel.DefaultChannelPromise.await(DefaultChannelPromise.java:28)
> at
> com.basho.riak.client.core.RiakNode.doGetConnection(RiakNode.java:697)
> at
> com.basho.riak.client.core.RiakNode.getConnection(RiakNode.java:656)
> at com.basho.riak.client.core.RiakNode.execute(RiakNode.java:587)
> at
> com.basho.riak.client.core.DefaultNodeManager.executeOnNode(DefaultNodeManager.java:91)
> at
> com.basho.riak.client.core.RiakCluster.execute(RiakCluster.java:322)
> at
> com.basho.riak.client.core.RiakCluster.execute(RiakCluster.java:240)
> at
> com.basho.riak.client.api.commands.kv.StoreValue.executeAsync(StoreValue.java:117)
> at
> com.basho.riak.client.api.commands.kv.UpdateValue$1.handle(UpdateValue.java:182)
> at
> com.basho.riak.client.api.commands.ListenableFuture.notifyListeners(ListenableFuture.java:78)
> at
> com.basho.riak.client.api.commands.CoreFutureAdapter.handle(CoreFutureAdapter.java:120)
> at
> com.basho.riak.client.core.FutureOperation.fireListeners(FutureOperation.java:176)
> at
> com.basho.riak.client.core.FutureOperation.setComplete(FutureOperation.java:224)
> at com.basho.riak.client.core.RiakNode.onSuccess(RiakNode.java:878)
> at
> com.basho.riak.client.core.netty.RiakResponseHandler.channelRead(RiakResponseHandler.java:30)
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:318)
> at
> io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:304)
> at
> io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:276)
> at
> io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:263)
> at
> io.netty.handler.codec.ByteToMessageCodec.channelRead(ByteToMessageCodec.java:103)
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:318)
> at
> io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:304)
> at
> io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:846)
> at
> io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:131)
> at
> io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511)
> at
> io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468)
> at
> io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382)
> at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)
> at
> io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:112)
> at
> io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137)
> at java.lang.Thread.run(Thread.java:745)
>
> Then shortly thereafter:
>
> 2016-07-13 14:41:12.820 localhost [nioEventLoopGroup-2-2] ERROR
> com.basho.riak.client.core.RiakNode - Write failed on RiakNode
> localhost:8087 id: 237445453; cause: {}
> java.nio.channels.ClosedChannelException: null
> 2016-
Re: Create Bucket failed
Salman -
Can you provide more detailed debugging logs from s3cmd or some way to
reproduce this?
--
Luke Bakken
Engineer
lbak...@basho.com
On Wed, Jul 13, 2016 at 3:34 AM, Salman Khaleghian wrote:
> Hello
> I use cloudberry and s3cmd both. Both of them show internal server error.
> Bests
>
>
> On Tue, 12 Jul 2016 19:33:37 +0430 Luke Bakken wrote
>
>
> What tool are you using to create buckets? If you can provide debug
> output, it looks as though the message sent to Riak CS is bad ("error,
> malformed_xml")
>
> --
> Luke Bakken
> Engineer
> lbak...@basho.com
>
>
> On Sat, Jul 9, 2016 at 1:11 AM, s251251251 wrote:
>> Hello
>> after some day after riak-cs Installation, I can not create bucket. Server
>> Error is:
>>
>> 2016-07-09 12:36:15.401 [error] <0.796.0> Webmachine error at path
>> "/buckets/test" :
>>
>> {error,{error,{badmatch,{error,malformed_xml}},[{riak_cs_s3_response,xml_error_code,1,[{file,"src/riak_cs_s3_response.erl"},{line,396}]},{riak_cs_s3_response,error_response,1,[{file,"src/riak_cs_s3_response.erl"},{line,273}]},{riak_cs_wm_bucket,accept_body,2,[{file,"src/riak_cs_wm_bucket.erl"},{line,130}]},{riak_cs_wm_common,accept_body,2,[{file,"src/riak_cs_wm_common.erl"},{line,342}]},{webmachine_resource,resource_call,3,[{file,"src/webmachine_resource.erl"},{line,186}]},{webmachine_resource,...},...]}}
>> in riak_cs_s3_response:xml_error_code/1 line 396
>>
>> however i can get and put files. stanchion started.
___
riak-users mailing list
riak-users@lists.basho.com
http://lists.basho.com/mailman/listinfo/riak-users_lists.basho.com
