Re: ServerError: An unexpected error occurred server side; in cassandra java driver

[Tyler Hobbs]

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.siddha...@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 

Re: ServerError: An unexpected error occurred server side; in cassandra java driver

[Siddharth Verma]

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

[Siddharth Verma]

Correction : java driver version : 3.1.0

Re: ServerError: An unexpected error occurred server side; in cassandra java driver

[Siddharth Verma]

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

[Siddharth Verma]

Hi Ben
1. cassandra 3.6
2. driver 3.2
3. Statement : select * from my_ks.my_table1 where token(pk1) >= ? and
token(pk1) https://play.google.com/store/apps/details?id=com.snapdeal.main&utm_source=mobileAppLp&utm_campaign=android>
[image:
A]

[image:
W]


On Thu, Sep 1, 2016 at 4:56 PM, Ben Slater 
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 
> 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)
>>

Re: ServerError: An unexpected error occurred server side; in cassandra java driver

[Ben Slater]

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 
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