On 19.12.2013, at 14:09, Sylvain Lebresne <sylv...@datastax.com> wrote:
> > > Is there anything I can do except waiting for a fix? > > Disable paging (which might imply having to do some manual paging if the > result set you were querying were really big). Yes, that was my original code - might do that. > > I'll note that while far from idea, you can also disable assertion with 2.0.3. Is there a way to do that without patching/recompiling?? You make it sound as if there is... > If you do so, the code won't crash, but you might get twice the same row > during some paging. No big deal - easily done in my code and far better than lossing around 5% (in my case) of the rows with 2.0.1 > That's still probably better than going back to 2.0.1 though. > And of course, another option could be to apply manually the patch that is on > the issue and/or use the current tip of the cassandra-1.2 branch. As I am on Debian packages, I'd rather not :-) Thanks for the quick insights! Jan > > -- > Sylvain > > > On 19.12.2013, at 11:39, Sylvain Lebresne <sylv...@datastax.com> wrote: > > > https://issues.apache.org/jira/browse/CASSANDRA-6447 > > > > > > On Thu, Dec 19, 2013 at 11:16 AM, Jan Algermissen > > <jan.algermis...@nordsc.com> wrote: > > Hi all, > > > > after upgrading C* and the java-driver I am running into problems with > > paging. Maybe someone can provide a quick clue. > > > > Upgrading was > > C* from 2.0.1 to 2.0.3 > > Java Driver from 2.0.0-rc1 to 2.0.0-rc2 > > > > > > > > Client side, I get the following messages (apparently during a call to > > resultSet.one() ): > > > > > > com.datastax.driver.core.exceptions.DriverInternalError: An unexpected > > error occured server side on /37.139.24.133: java.l > > ang.AssertionError > > at > > com.datastax.driver.core.exceptions.DriverInternalError.copy(DriverInternalError.java:42) > > at > > com.datastax.driver.core.ResultSetFuture.extractCauseFromExecutionException(ResultSetFuture.java:271) > > at > > com.datastax.driver.core.ResultSet.fetchMoreResultsBlocking(ResultSet.java:252) > > at com.datastax.driver.core.ResultSet.one(ResultSet.java:166) > > .... > > > > > > Server Side: > > > > INFO [HANDSHAKE-/37.139.3.70] 2013-12-19 09:55:11,277 > > OutboundTcpConnection.java (line 386) Handshaking version with /37.139.3.70 > > INFO [HANDSHAKE-/37.139.24.133] 2013-12-19 09:55:11,284 > > OutboundTcpConnection.java (line 386) Handshaking version with > > /37.139.24.133 > > INFO [HANDSHAKE-/37.139.24.133] 2013-12-19 09:55:11,309 > > OutboundTcpConnection.java (line 386) Handshaking version with > > /37.139.24.133 > > INFO [HANDSHAKE-/146.185.135.226] 2013-12-19 10:00:10,077 > > OutboundTcpConnection.java (line 386) Handshaking version with > > /146.185.135.226 > > WARN [ReadStage:87] 2013-12-19 10:00:16,490 SliceQueryFilter.java (line > > 209) Read 111 live and 1776 tombstoned cells (see tombstone_warn_threshold) > > WARN [ReadStage:87] 2013-12-19 10:00:16,976 SliceQueryFilter.java (line > > 209) Read 48 live and 1056 tombstoned cells (see tombstone_warn_threshold) > > WARN [ReadStage:87] 2013-12-19 10:00:18,588 SliceQueryFilter.java (line > > 209) Read 80 live and 1160 tombstoned cells (see tombstone_warn_threshold) > > WARN [ReadStage:88] 2013-12-19 10:00:24,675 SliceQueryFilter.java (line > > 209) Read 48 live and 1056 tombstoned cells (see tombstone_warn_threshold) > > WARN [ReadStage:88] 2013-12-19 10:00:25,715 SliceQueryFilter.java (line > > 209) Read 80 live and 1160 tombstoned cells (see tombstone_warn_threshold) > > WARN [ReadStage:89] 2013-12-19 10:00:31,406 SliceQueryFilter.java (line > > 209) Read 300 live and 6300 tombstoned cells (see tombstone_warn_threshold) > > WARN [ReadStage:89] 2013-12-19 10:00:32,075 SliceQueryFilter.java (line > > 209) Read 65 live and 1040 tombstoned cells (see tombstone_warn_threshold) > > WARN [ReadStage:89] 2013-12-19 10:00:33,207 SliceQueryFilter.java (line > > 209) Read 72 live and 1224 tombstoned cells (see tombstone_warn_threshold) > > WARN [ReadStage:90] 2013-12-19 10:00:37,183 SliceQueryFilter.java (line > > 209) Read 135 live and 1782 tombstoned cells (see tombstone_warn_threshold) > > INFO [ScheduledTasks:1] 2013-12-19 10:00:58,523 GCInspector.java (line > > 116) GC for ParNew: 213 ms for 1 collections, 720697792 used; max is > > 2057306112 > > ERROR [Native-Transport-Requests:216] 2013-12-19 10:00:58,913 > > ErrorMessage.java (line 222) Unexpected exception during request > > java.lang.AssertionError > > at > > org.apache.cassandra.service.pager.AbstractQueryPager.discardFirst(AbstractQueryPager.java:183) > > at > > org.apache.cassandra.service.pager.AbstractQueryPager.fetchPage(AbstractQueryPager.java:102) > > at > > org.apache.cassandra.service.pager.RangeSliceQueryPager.fetchPage(RangeSliceQueryPager.java:36) > > at > > org.apache.cassandra.cql3.statements.SelectStatement.execute(SelectStatement.java:171) > > at > > org.apache.cassandra.cql3.statements.SelectStatement.execute(SelectStatement.java:58) > > at > > org.apache.cassandra.cql3.QueryProcessor.processStatement(QueryProcessor.java:188) > > at > > org.apache.cassandra.cql3.QueryProcessor.process(QueryProcessor.java:222) > > at > > org.apache.cassandra.transport.messages.QueryMessage.execute(QueryMessage.java:119) > > at > > org.apache.cassandra.transport.Message$Dispatcher.messageReceived(Message.java:304) > > at > > org.jboss.netty.handler.execution.ChannelUpstreamEventRunnable.doRun(ChannelUpstreamEventRunnable.java:43) > > at > > org.jboss.netty.handler.execution.ChannelEventRunnable.run(ChannelEventRunnable.java:67) > > at > > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) > > at > > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) > > at java.lang.Thread.run(Thread.java:744) > > > > > > > > > > Jan > > > >
