You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@cassandra.apache.org by Siddharth Verma <ve...@snapdeal.com> on 2016/09/01 11:19:04 UTC
ServerError: An unexpected error occurred server side; in cassandra
java driver
Hi,
Could someone help me out with the following exception in cassandra java
driver.
Why did it occur?
MyClass program is paging on the result set.
com.datastax.driver.core.exceptions.ServerError: An unexpected error
occurred server side on /10.0.230.25:9042: java.lang.AssertionError:
[DecoratedKey(3529259302770464040,
53444c373134303435333030),min(2177391360409801028)]
at
com.datastax.driver.core.exceptions.ServerError.copy(ServerError.java:63)
at
com.datastax.driver.core.exceptions.ServerError.copy(ServerError.java:25)
at
com.datastax.driver.core.DriverThrowables.propagateCause(DriverThrowables.java:37)
at
com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:245)
at
com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:64)
at com.personal.trial.MyClass.fetchLoop(MyClass.java:63)
at com.personal.trial.MyClass.run(MyClass.java:85)
Caused by: com.datastax.driver.core.exceptions.ServerError: An unexpected
error occurred server side on /10.0.230.25:9042: java.lang.AssertionError:
[DecoratedKey(3529259302770464040,
53444c373134303435333030),min(2177391360409801028)]
at
com.datastax.driver.core.Responses$Error.asException(Responses.java:108)
at
com.datastax.driver.core.RequestHandler$SpeculativeExecution.onSet(RequestHandler.java:500)
at
com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:1012)
at
com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:935)
at
io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:342)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:328)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:321)
at
io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:266)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:342)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:328)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:321)
at
io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:342)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:328)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:321)
at
io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:293)
at
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:267)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:342)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:328)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:321)
at
io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1280)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:342)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:328)
at
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:890)
at
io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:131)
at
io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:564)
at
io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:505)
at
io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:419)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:391)
at
io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:112)
at java.lang.Thread.run(Thread.java:745)
Thanks
Siddharth
Re: ServerError: An unexpected error occurred server side; in
cassandra java driver
Posted by Tyler Hobbs <ty...@datastax.com>.
There should be a corresponding error and stacktrace in your cassandra logs
on 10.0.230.25. Please find that and post it, if you can.
On Thu, Sep 1, 2016 at 7:23 AM, Siddharth Verma <
verma.siddharth@snapdeal.com> wrote:
> Debugged the issue a little.
> AbstractFuture.get() throws java.util..concurrent.ExecutionException
> in, Uninterruptables.getUninterruptibly interrupted gets set to true,
> which does Thread.interrupt()
> thus in DefaultResultSetFuture (ResultSet)Uninterruptibles.getUninterruptibly(this)
> throws exception.
>
> If someone who might have faced a similar issue could provide his/her
> views.
>
> Thanks
> Siddharth
>
--
Tyler Hobbs
DataStax <http://datastax.com/>
Re: ServerError: An unexpected error occurred server side; in
cassandra java driver
Posted by Siddharth Verma <ve...@snapdeal.com>.
Debugged the issue a little.
AbstractFuture.get() throws java.util..concurrent.ExecutionException
in, Uninterruptables.getUninterruptibly interrupted gets set to true, which
does Thread.interrupt()
thus in DefaultResultSetFuture
(ResultSet)Uninterruptibles.getUninterruptibly(this) throws exception.
If someone who might have faced a similar issue could provide his/her views.
Thanks
Siddharth
Re: ServerError: An unexpected error occurred server side; in
cassandra java driver
Posted by Siddharth Verma <ve...@snapdeal.com>.
Correction : java driver version : 3.1.0
Re: ServerError: An unexpected error occurred server side; in
cassandra java driver
Posted by Siddharth Verma <ve...@snapdeal.com>.
Update :
I page on the ResultSet explicitly in the program(
*boundStatement.setPagingState(PagingState.fromString(currentPageInfo));*)
When i put a *limit 10* after select statement, there is no error, with the
token range set i provided it
However, without that, there is this error, on second token range set.
Thanks
Siddharth
Re: ServerError: An unexpected error occurred server side; in
cassandra java driver
Posted by Siddharth Verma <ve...@snapdeal.com>.
Hi Ben
1. cassandra 3.6
2. driver 3.2
3. Statement : select * from my_ks.my_table1 where token(pk1) >= ? and
token(pk1) <?;
4. Schema:
pk1 text,
ck1 bigint,
ck2 int,
col1 text,
col2 text
PRIMARY KEY (pk1, ck1, ck2)
5. I created my own LoadBalancingPolicy similar to the lines of DCAware
policy.
Thanks
Siddharth
Siddharth Verma
*Software Engineer I - CaMS*
*M*: +91 9013689856, *T*: 011 22791596 *EXT*: 14697
CA2125, 2nd Floor, ASF Centre-A, Jwala Mill Road,
Udyog Vihar Phase - IV, Gurgaon-122016, INDIA
Download Our App
[image: A]
<https://play.google.com/store/apps/details?id=com.snapdeal.main&utm_source=mobileAppLp&utm_campaign=android>
[image:
A]
<https://itunes.apple.com/in/app/snapdeal-mobile-shopping/id721124909?ls=1&mt=8&utm_source=mobileAppLp&utm_campaign=ios>
[image:
W]
<http://www.windowsphone.com/en-in/store/app/snapdeal/ee17fccf-40d0-4a59-80a3-04da47a5553f>
On Thu, Sep 1, 2016 at 4:56 PM, Ben Slater <be...@instaclustr.com>
wrote:
> Hi Siddarth,
>
> It would probably help people provide and answer if you let everyone some
> more details like:
> - cassandra version and driver version you are using
> - query that is being executed when the error occurs
> - schema of the table that is being queried
>
> Cheers
> Ben
>
> On Thu, 1 Sep 2016 at 21:19 Siddharth Verma <ve...@snapdeal.com>
> wrote:
>
>> Hi,
>> Could someone help me out with the following exception in cassandra java
>> driver.
>> Why did it occur?
>> MyClass program is paging on the result set.
>>
>> com.datastax.driver.core.exceptions.ServerError: An unexpected error
>> occurred server side on /10.0.230.25:9042: java.lang.AssertionError:
>> [DecoratedKey(3529259302770464040, 53444c373134303435333030),min(
>> 2177391360409801028)]
>> at com.datastax.driver.core.exceptions.ServerError.copy(
>> ServerError.java:63)
>> at com.datastax.driver.core.exceptions.ServerError.copy(
>> ServerError.java:25)
>> at com.datastax.driver.core.DriverThrowables.propagateCause(
>> DriverThrowables.java:37)
>> at com.datastax.driver.core.DefaultResultSetFuture.
>> getUninterruptibly(DefaultResultSetFuture.java:245)
>> at com.datastax.driver.core.AbstractSession.execute(
>> AbstractSession.java:64)
>> at com.personal.trial.MyClass.fetchLoop(MyClass.java:63)
>> at com.personal.trial.MyClass.run(MyClass.java:85)
>> Caused by: com.datastax.driver.core.exceptions.ServerError: An
>> unexpected error occurred server side on /10.0.230.25:9042:
>> java.lang.AssertionError: [DecoratedKey(3529259302770464040,
>> 53444c373134303435333030),min(2177391360409801028)]
>> at com.datastax.driver.core.Responses$Error.asException(
>> Responses.java:108)
>> at com.datastax.driver.core.RequestHandler$
>> SpeculativeExecution.onSet(RequestHandler.java:500)
>> at com.datastax.driver.core.Connection$Dispatcher.
>> channelRead0(Connection.java:1012)
>> at com.datastax.driver.core.Connection$Dispatcher.
>> channelRead0(Connection.java:935)
>> at io.netty.channel.SimpleChannelInboundHandler.channelRead(
>> SimpleChannelInboundHandler.java:105)
>> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(
>> AbstractChannelHandlerContext.java:342)
>> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(
>> AbstractChannelHandlerContext.java:328)
>> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(
>> AbstractChannelHandlerContext.java:321)
>> at io.netty.handler.timeout.IdleStateHandler.channelRead(
>> IdleStateHandler.java:266)
>> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(
>> AbstractChannelHandlerContext.java:342)
>> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(
>> AbstractChannelHandlerContext.java:328)
>> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(
>> AbstractChannelHandlerContext.java:321)
>> at io.netty.handler.codec.MessageToMessageDecoder.channelRead(
>> MessageToMessageDecoder.java:102)
>> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(
>> AbstractChannelHandlerContext.java:342)
>> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(
>> AbstractChannelHandlerContext.java:328)
>> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(
>> AbstractChannelHandlerContext.java:321)
>> at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(
>> ByteToMessageDecoder.java:293)
>> at io.netty.handler.codec.ByteToMessageDecoder.channelRead(
>> ByteToMessageDecoder.java:267)
>> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(
>> AbstractChannelHandlerContext.java:342)
>> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(
>> AbstractChannelHandlerContext.java:328)
>> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(
>> AbstractChannelHandlerContext.java:321)
>> at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(
>> DefaultChannelPipeline.java:1280)
>> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(
>> AbstractChannelHandlerContext.java:342)
>> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(
>> AbstractChannelHandlerContext.java:328)
>> at io.netty.channel.DefaultChannelPipeline.fireChannelRead(
>> DefaultChannelPipeline.java:890)
>> at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(
>> AbstractNioByteChannel.java:131)
>> at io.netty.channel.nio.NioEventLoop.processSelectedKey(
>> NioEventLoop.java:564)
>> at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(
>> NioEventLoop.java:505)
>> at io.netty.channel.nio.NioEventLoop.processSelectedKeys(
>> NioEventLoop.java:419)
>> at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:391)
>> at io.netty.util.concurrent.SingleThreadEventExecutor$2.
>> run(SingleThreadEventExecutor.java:112)
>> at java.lang.Thread.run(Thread.java:745)
>>
>> Thanks
>> Siddharth
>>
> --
> ————————
> Ben Slater
> Chief Product Officer
> Instaclustr: Cassandra + Spark - Managed | Consulting | Support
> +61 437 929 798
>
Re: ServerError: An unexpected error occurred server side; in
cassandra java driver
Posted by Ben Slater <be...@instaclustr.com>.
Hi Siddarth,
It would probably help people provide and answer if you let everyone some
more details like:
- cassandra version and driver version you are using
- query that is being executed when the error occurs
- schema of the table that is being queried
Cheers
Ben
On Thu, 1 Sep 2016 at 21:19 Siddharth Verma <ve...@snapdeal.com>
wrote:
> Hi,
> Could someone help me out with the following exception in cassandra java
> driver.
> Why did it occur?
> MyClass program is paging on the result set.
>
> com.datastax.driver.core.exceptions.ServerError: An unexpected error
> occurred server side on /10.0.230.25:9042: java.lang.AssertionError:
> [DecoratedKey(3529259302770464040,
> 53444c373134303435333030),min(2177391360409801028)]
> at
> com.datastax.driver.core.exceptions.ServerError.copy(ServerError.java:63)
> at
> com.datastax.driver.core.exceptions.ServerError.copy(ServerError.java:25)
> at
> com.datastax.driver.core.DriverThrowables.propagateCause(DriverThrowables.java:37)
> at
> com.datastax.driver.core.DefaultResultSetFuture.getUninterruptibly(DefaultResultSetFuture.java:245)
> at
> com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:64)
> at com.personal.trial.MyClass.fetchLoop(MyClass.java:63)
> at com.personal.trial.MyClass.run(MyClass.java:85)
> Caused by: com.datastax.driver.core.exceptions.ServerError: An unexpected
> error occurred server side on /10.0.230.25:9042:
> java.lang.AssertionError: [DecoratedKey(3529259302770464040,
> 53444c373134303435333030),min(2177391360409801028)]
> at
> com.datastax.driver.core.Responses$Error.asException(Responses.java:108)
> at
> com.datastax.driver.core.RequestHandler$SpeculativeExecution.onSet(RequestHandler.java:500)
> at
> com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:1012)
> at
> com.datastax.driver.core.Connection$Dispatcher.channelRead0(Connection.java:935)
> at
> io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:342)
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:328)
> at
> io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:321)
> at
> io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:266)
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:342)
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:328)
> at
> io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:321)
> at
> io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102)
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:342)
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:328)
> at
> io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:321)
> at
> io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:293)
> at
> io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:267)
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:342)
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:328)
> at
> io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:321)
> at
> io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1280)
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:342)
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:328)
> at
> io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:890)
> at
> io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:131)
> at
> io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:564)
> at
> io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:505)
> at
> io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:419)
> at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:391)
> at
> io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:112)
> at java.lang.Thread.run(Thread.java:745)
>
> Thanks
> Siddharth
>
--
————————
Ben Slater
Chief Product Officer
Instaclustr: Cassandra + Spark - Managed | Consulting | Support
+61 437 929 798