[
https://issues.apache.org/jira/browse/CASSANDRA-13236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15872530#comment-15872530
]
Alex Petrov commented on CASSANDRA-13236:
-----------------------------------------
+1 on what [~Stefania] said.
Sometimes it's also useful to compare the outputs from the old and new
sstables, might be helpful to understand how to fix the upgrade path.
If you can't show the sstables, you could also try hex-dumping the part of
buffer on the exception (with {{ByteBufferUtil#bytesAsHex}}), this way you can
understand if the sstable is completely off, or it's just this single byte is
written incorrectly. Sometimes the offsets might be wrong, which leads into
reader jumping and starting reading from the wrong point in the sstable.
> corrupt flag error after upgrade from 2.2 to 3.0.10
> ---------------------------------------------------
>
> Key: CASSANDRA-13236
> URL: https://issues.apache.org/jira/browse/CASSANDRA-13236
> Project: Cassandra
> Issue Type: Bug
> Environment: cassandra 3.0.10
> Reporter: ingard mevåg
>
> After upgrade from 2.2.5 to 3.0.9/10 we're getting a bunch of errors like
> this:
> {code}
> ERROR [SharedPool-Worker-1] 2017-02-17 12:58:43,859 Message.java:617 -
> Unexpected exception during request; channel = [id: 0xa8b98684,
> /10.0.70.104:56814 => /10.0.80.24:9042]
> java.io.IOError: java.io.IOException: Corrupt flags value for unfiltered
> partition (isStatic flag set): 160
> at
> org.apache.cassandra.db.rows.UnfilteredRowIteratorSerializer$1.computeNext(UnfilteredRowIteratorSerializer.java:222)
> ~[apache-cassandra-3.0.10.jar:3.0.10]
> at
> org.apache.cassandra.db.rows.UnfilteredRowIteratorSerializer$1.computeNext(UnfilteredRowIteratorSerializer.java:210)
> ~[apache-cassandra-3.0.10.jar:3.0.10]
> at
> org.apache.cassandra.utils.AbstractIterator.hasNext(AbstractIterator.java:47)
> ~[apache-cassandra-3.0.10.jar:3.0.10]
> at
> org.apache.cassandra.db.transform.BaseRows.hasNext(BaseRows.java:129)
> ~[apache-cassandra-3.0.10.jar:3.0.10]
> at
> org.apache.cassandra.cql3.statements.SelectStatement.processPartition(SelectStatement.java:749)
> ~[apache-cassandra-3.0.10.jar:3.0.10]
> at
> org.apache.cassandra.cql3.statements.SelectStatement.process(SelectStatement.java:711)
> ~[apache-cassandra-3.0.10.jar:3.0.10]
> at
> org.apache.cassandra.cql3.statements.SelectStatement.processResults(SelectStatement.java:400)
> ~[apache-cassandra-3.0.10.jar:3.0.10]
> at
> org.apache.cassandra.cql3.statements.SelectStatement.execute(SelectStatement.java:265)
> ~[apache-cassandra-3.0.10.jar:3.0.10]
> at
> org.apache.cassandra.cql3.statements.SelectStatement.execute(SelectStatement.java:224)
> ~[apache-cassandra-3.0.10.jar:3.0.10]
> at
> org.apache.cassandra.cql3.statements.SelectStatement.execute(SelectStatement.java:76)
> ~[apache-cassandra-3.0.10.jar:3.0.10]
> at
> org.apache.cassandra.cql3.QueryProcessor.processStatement(QueryProcessor.java:206)
> ~[apache-cassandra-3.0.10.jar:3.0.10]
> at
> org.apache.cassandra.cql3.QueryProcessor.processPrepared(QueryProcessor.java:487)
> ~[apache-cassandra-3.0.10.jar:3.0.10]
> at
> org.apache.cassandra.cql3.QueryProcessor.processPrepared(QueryProcessor.java:464)
> ~[apache-cassandra-3.0.10.jar:3.0.10]
> at
> org.apache.cassandra.transport.messages.ExecuteMessage.execute(ExecuteMessage.java:130)
> ~[apache-cassandra-3.0.10.jar:3.0.10]
> at
> org.apache.cassandra.transport.Message$Dispatcher.channelRead0(Message.java:513)
> [apache-cassandra-3.0.10.jar:3.0.10]
> at
> org.apache.cassandra.transport.Message$Dispatcher.channelRead0(Message.java:407)
> [apache-cassandra-3.0.10.jar:3.0.10]
> at
> io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)
> [netty-all-4.0.23.Final.jar:4.0.23.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333)
> [netty-all-4.0.23.Final.jar:4.0.23.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext.access$700(AbstractChannelHandlerContext.java:32)
> [netty-all-4.0.23.Final.jar:4.0.23.Final]
> at
> io.netty.channel.AbstractChannelHandlerContext$8.run(AbstractChannelHandlerContext.java:324)
> [netty-all-4.0.23.Final.jar:4.0.23.Final]
> at
> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
> [na:1.8.0_72]
> at
> org.apache.cassandra.concurrent.AbstractLocalAwareExecutorService$FutureTask.run(AbstractLocalAwareExecutorService.java:164)
> [apache-cassandra-3.0.10.jar:3.0.10]
> at org.apache.cassandra.concurrent.SEPWorker.run(SEPWorker.java:105)
> [apache-cassandra-3.0.10.jar:3.0.10]
> at java.lang.Thread.run(Thread.java:745) [na:1.8.0_72]
> Caused by: java.io.IOException: Corrupt flags value for unfiltered partition
> (isStatic flag set): 160
> at
> org.apache.cassandra.db.rows.UnfilteredSerializer.deserialize(UnfilteredSerializer.java:374)
> ~[apache-cassandra-3.0.10.jar:3.0.10]
> at
> org.apache.cassandra.db.rows.UnfilteredRowIteratorSerializer$1.computeNext(UnfilteredRowIteratorSerializer.java:217)
> ~[apache-cassandra-3.0.10.jar:3.0.10]
> ... 23 common frames omitted
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
