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 <ben.sla...@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 <verma.siddha...@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 >
