cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Tania S Engel (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (CASSANDRA-13608) Connection closed/reopened during join causes Cassandra stream to close
Date Tue, 25 Jul 2017 15:00:02 GMT

     [ https://issues.apache.org/jira/browse/CASSANDRA-13608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Tania S Engel updated CASSANDRA-13608:
--------------------------------------
    Description: 
We use MVs. We start a JOIN bootstrap. Primary seed node streams to the replica. The replica
requires some GC cleanup and experiences frequent pauses including a 12 second old gen cleanup
following a memTable flush. Both replica and primary show _MessagingService IOException: An
existing connection was forcibly closed by the remote host_. The replica MessagingService-Outgoing
reestablishes the connection immediately but the primary StreamKeepAliveExecutor throws a
_java.RuntimeException: Outgoing stream handler has been closed_. From that point forward,
the replica stays in JOIN mode, sending keeping alive to the primary. The primary receives
the keep alive, but does not send its own and it repeatedly fails to send a hints file to
the replica. It seems this limping condition would continue indefinitely, but stops as we
stop the replica Cassandra. If we restart the replica Cassandra the JOIN picks up again but
fails with _java.io.IOException: Corrupt value length 355151036 encountered, as it exceeds
the maximum of 268435456, which is set via max_value_size_in_mb in cassandra.yaml_. We have
not increased this value as we do not have values that large in our data so we presume it
is indeed corrupt and moving past it would not be a good idea. Please see the attachment for
details.

{code}
ERROR [BatchlogTasks:1] 2017-06-13 20:24:13,953 CassandraDaemon.java:229 - Exception in thread
Thread[BatchlogTasks:1,5,main]
org.apache.cassandra.io.sstable.CorruptSSTableException: Corrupted: C:\Cassandra\data\data\system\batches-919a4bc57a333573b03e13fc3f68b465\mc-2-big-Data.db
	at org.apache.cassandra.db.columniterator.AbstractSSTableIterator$Reader.hasNext(AbstractSSTableIterator.java:395)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.columniterator.AbstractSSTableIterator.hasNext(AbstractSSTableIterator.java:257)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.computeNext(LazilyInitializedUnfilteredRowIterator.java:100)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.computeNext(LazilyInitializedUnfilteredRowIterator.java:32)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.utils.AbstractIterator.hasNext(AbstractIterator.java:47) ~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.computeNext(LazilyInitializedUnfilteredRowIterator.java:100)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.computeNext(LazilyInitializedUnfilteredRowIterator.java:32)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.utils.AbstractIterator.hasNext(AbstractIterator.java:47) ~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.transform.BaseRows.hasNext(BaseRows.java:133) ~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.transform.UnfilteredRows.isEmpty(UnfilteredRows.java:69) ~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.partitions.PurgeFunction.applyToPartition(PurgeFunction.java:67)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.partitions.PurgeFunction.applyToPartition(PurgeFunction.java:26)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.transform.BasePartitions.hasNext(BasePartitions.java:96) ~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.cql3.statements.SelectStatement.process(SelectStatement.java:755)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.cql3.statements.SelectStatement.process(SelectStatement.java:446)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.cql3.UntypedResultSet$FromPager$1.computeNext(UntypedResultSet.java:193)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.cql3.UntypedResultSet$FromPager$1.computeNext(UntypedResultSet.java:179)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.utils.AbstractIterator.hasNext(AbstractIterator.java:47) ~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.batchlog.BatchlogManager.processBatchlogEntries(BatchlogManager.java:233)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.batchlog.BatchlogManager.replayFailedBatches(BatchlogManager.java:209)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.concurrent.DebuggableScheduledThreadPoolExecutor$UncomplainingRunnable.run(DebuggableScheduledThreadPoolExecutor.java:118)
~[apache-cassandra-3.10.jar:3.10]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_66]
	at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) [na:1.8.0_66]
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
[na:1.8.0_66]
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
[na:1.8.0_66]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_66]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_66]
	at org.apache.cassandra.concurrent.NamedThreadFactory.lambda$threadLocalDeallocator$0(NamedThreadFactory.java:79)
[apache-cassandra-3.10.jar:3.10]
	at java.lang.Thread.run(Thread.java:745) ~[na:1.8.0_66]
Caused by: java.io.IOException: Corrupt value length 355151036 encountered, as it exceeds
the maximum of 268435456, which is set via max_value_size_in_mb in cassandra.yaml
	at org.apache.cassandra.db.marshal.AbstractType.readValue(AbstractType.java:428) ~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.rows.Cell$Serializer.deserialize(Cell.java:245) ~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.rows.UnfilteredSerializer.readComplexColumn(UnfilteredSerializer.java:636)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.rows.UnfilteredSerializer.lambda$deserializeRowBody$1(UnfilteredSerializer.java:577)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.utils.btree.BTree.applyForwards(BTree.java:1222) ~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.utils.btree.BTree.apply(BTree.java:1177) ~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.Columns.apply(Columns.java:377) ~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.rows.UnfilteredSerializer.deserializeRowBody(UnfilteredSerializer.java:571)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.UnfilteredDeserializer$CurrentDeserializer.readNext(UnfilteredDeserializer.java:211)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.columniterator.SSTableIterator$ForwardReader.computeNext(SSTableIterator.java:144)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.columniterator.SSTableIterator$ForwardReader.hasNextInternal(SSTableIterator.java:168)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.columniterator.AbstractSSTableIterator$Reader.hasNext(AbstractSSTableIterator.java:382)
~[apache-cassandra-3.10.jar:3.10]
{code}

  was:
We start a JOIN bootstrap. Primary seed node streams to the replica. The replica requires
some GC cleanup and experiences frequent pauses including a 12 second old gen cleanup following
a memTable flush. Both replica and primary show _MessagingService IOException: An existing
connection was forcibly closed by the remote host_. The replica MessagingService-Outgoing
reestablishes the connection immediately but the primary StreamKeepAliveExecutor throws a
_java.RuntimeException: Outgoing stream handler has been closed_. From that point forward,
the replica stays in JOIN mode, sending keeping alive to the primary. The primary receives
the keep alive, but does not send its own and it repeatedly fails to send a hints file to
the replica. It seems this limping condition would continue indefinitely, but stops as we
stop the replica Cassandra. If we restart the replica Cassandra the JOIN picks up again but
fails with _java.io.IOException: Corrupt value length 355151036 encountered, as it exceeds
the maximum of 268435456, which is set via max_value_size_in_mb in cassandra.yaml_. We have
not increased this value as we do not have values that large in our data so we presume it
is indeed corrupt and moving past it would not be a good idea. Please see the attachment for
details.

{code}
ERROR [BatchlogTasks:1] 2017-06-13 20:24:13,953 CassandraDaemon.java:229 - Exception in thread
Thread[BatchlogTasks:1,5,main]
org.apache.cassandra.io.sstable.CorruptSSTableException: Corrupted: C:\Cassandra\data\data\system\batches-919a4bc57a333573b03e13fc3f68b465\mc-2-big-Data.db
	at org.apache.cassandra.db.columniterator.AbstractSSTableIterator$Reader.hasNext(AbstractSSTableIterator.java:395)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.columniterator.AbstractSSTableIterator.hasNext(AbstractSSTableIterator.java:257)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.computeNext(LazilyInitializedUnfilteredRowIterator.java:100)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.computeNext(LazilyInitializedUnfilteredRowIterator.java:32)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.utils.AbstractIterator.hasNext(AbstractIterator.java:47) ~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.computeNext(LazilyInitializedUnfilteredRowIterator.java:100)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.computeNext(LazilyInitializedUnfilteredRowIterator.java:32)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.utils.AbstractIterator.hasNext(AbstractIterator.java:47) ~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.transform.BaseRows.hasNext(BaseRows.java:133) ~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.transform.UnfilteredRows.isEmpty(UnfilteredRows.java:69) ~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.partitions.PurgeFunction.applyToPartition(PurgeFunction.java:67)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.partitions.PurgeFunction.applyToPartition(PurgeFunction.java:26)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.transform.BasePartitions.hasNext(BasePartitions.java:96) ~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.cql3.statements.SelectStatement.process(SelectStatement.java:755)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.cql3.statements.SelectStatement.process(SelectStatement.java:446)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.cql3.UntypedResultSet$FromPager$1.computeNext(UntypedResultSet.java:193)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.cql3.UntypedResultSet$FromPager$1.computeNext(UntypedResultSet.java:179)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.utils.AbstractIterator.hasNext(AbstractIterator.java:47) ~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.batchlog.BatchlogManager.processBatchlogEntries(BatchlogManager.java:233)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.batchlog.BatchlogManager.replayFailedBatches(BatchlogManager.java:209)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.concurrent.DebuggableScheduledThreadPoolExecutor$UncomplainingRunnable.run(DebuggableScheduledThreadPoolExecutor.java:118)
~[apache-cassandra-3.10.jar:3.10]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_66]
	at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) [na:1.8.0_66]
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
[na:1.8.0_66]
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
[na:1.8.0_66]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_66]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_66]
	at org.apache.cassandra.concurrent.NamedThreadFactory.lambda$threadLocalDeallocator$0(NamedThreadFactory.java:79)
[apache-cassandra-3.10.jar:3.10]
	at java.lang.Thread.run(Thread.java:745) ~[na:1.8.0_66]
Caused by: java.io.IOException: Corrupt value length 355151036 encountered, as it exceeds
the maximum of 268435456, which is set via max_value_size_in_mb in cassandra.yaml
	at org.apache.cassandra.db.marshal.AbstractType.readValue(AbstractType.java:428) ~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.rows.Cell$Serializer.deserialize(Cell.java:245) ~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.rows.UnfilteredSerializer.readComplexColumn(UnfilteredSerializer.java:636)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.rows.UnfilteredSerializer.lambda$deserializeRowBody$1(UnfilteredSerializer.java:577)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.utils.btree.BTree.applyForwards(BTree.java:1222) ~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.utils.btree.BTree.apply(BTree.java:1177) ~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.Columns.apply(Columns.java:377) ~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.rows.UnfilteredSerializer.deserializeRowBody(UnfilteredSerializer.java:571)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.UnfilteredDeserializer$CurrentDeserializer.readNext(UnfilteredDeserializer.java:211)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.columniterator.SSTableIterator$ForwardReader.computeNext(SSTableIterator.java:144)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.columniterator.SSTableIterator$ForwardReader.hasNextInternal(SSTableIterator.java:168)
~[apache-cassandra-3.10.jar:3.10]
	at org.apache.cassandra.db.columniterator.AbstractSSTableIterator$Reader.hasNext(AbstractSSTableIterator.java:382)
~[apache-cassandra-3.10.jar:3.10]
{code}


> Connection closed/reopened during join causes Cassandra stream to close
> -----------------------------------------------------------------------
>
>                 Key: CASSANDRA-13608
>                 URL: https://issues.apache.org/jira/browse/CASSANDRA-13608
>             Project: Cassandra
>          Issue Type: Bug
>          Components: Streaming and Messaging
>         Environment: Cassandra 3.10. Windows Server 2016, 32GB ram, 2TB hard disk, RAID10
with 4 spindles, 8 Cores
>            Reporter: Tania S Engel
>            Assignee: Kurt Greaves
>         Attachments: Cassandra 3.10 Join with lots GC collection leads to socket closure
and join hang.mht, Cassandra 3.10 Join with lots GC collection leads to socket closure and
join hang.pdf, Cassandra 3.10 Join with lots GC collection leads to socket closure and join
hang.txt
>
>
> We use MVs. We start a JOIN bootstrap. Primary seed node streams to the replica. The
replica requires some GC cleanup and experiences frequent pauses including a 12 second old
gen cleanup following a memTable flush. Both replica and primary show _MessagingService IOException:
An existing connection was forcibly closed by the remote host_. The replica MessagingService-Outgoing
reestablishes the connection immediately but the primary StreamKeepAliveExecutor throws a
_java.RuntimeException: Outgoing stream handler has been closed_. From that point forward,
the replica stays in JOIN mode, sending keeping alive to the primary. The primary receives
the keep alive, but does not send its own and it repeatedly fails to send a hints file to
the replica. It seems this limping condition would continue indefinitely, but stops as we
stop the replica Cassandra. If we restart the replica Cassandra the JOIN picks up again but
fails with _java.io.IOException: Corrupt value length 355151036 encountered, as it exceeds
the maximum of 268435456, which is set via max_value_size_in_mb in cassandra.yaml_. We have
not increased this value as we do not have values that large in our data so we presume it
is indeed corrupt and moving past it would not be a good idea. Please see the attachment for
details.
> {code}
> ERROR [BatchlogTasks:1] 2017-06-13 20:24:13,953 CassandraDaemon.java:229 - Exception
in thread Thread[BatchlogTasks:1,5,main]
> org.apache.cassandra.io.sstable.CorruptSSTableException: Corrupted: C:\Cassandra\data\data\system\batches-919a4bc57a333573b03e13fc3f68b465\mc-2-big-Data.db
> 	at org.apache.cassandra.db.columniterator.AbstractSSTableIterator$Reader.hasNext(AbstractSSTableIterator.java:395)
~[apache-cassandra-3.10.jar:3.10]
> 	at org.apache.cassandra.db.columniterator.AbstractSSTableIterator.hasNext(AbstractSSTableIterator.java:257)
~[apache-cassandra-3.10.jar:3.10]
> 	at org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.computeNext(LazilyInitializedUnfilteredRowIterator.java:100)
~[apache-cassandra-3.10.jar:3.10]
> 	at org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.computeNext(LazilyInitializedUnfilteredRowIterator.java:32)
~[apache-cassandra-3.10.jar:3.10]
> 	at org.apache.cassandra.utils.AbstractIterator.hasNext(AbstractIterator.java:47) ~[apache-cassandra-3.10.jar:3.10]
> 	at org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.computeNext(LazilyInitializedUnfilteredRowIterator.java:100)
~[apache-cassandra-3.10.jar:3.10]
> 	at org.apache.cassandra.db.rows.LazilyInitializedUnfilteredRowIterator.computeNext(LazilyInitializedUnfilteredRowIterator.java:32)
~[apache-cassandra-3.10.jar:3.10]
> 	at org.apache.cassandra.utils.AbstractIterator.hasNext(AbstractIterator.java:47) ~[apache-cassandra-3.10.jar:3.10]
> 	at org.apache.cassandra.db.transform.BaseRows.hasNext(BaseRows.java:133) ~[apache-cassandra-3.10.jar:3.10]
> 	at org.apache.cassandra.db.transform.UnfilteredRows.isEmpty(UnfilteredRows.java:69)
~[apache-cassandra-3.10.jar:3.10]
> 	at org.apache.cassandra.db.partitions.PurgeFunction.applyToPartition(PurgeFunction.java:67)
~[apache-cassandra-3.10.jar:3.10]
> 	at org.apache.cassandra.db.partitions.PurgeFunction.applyToPartition(PurgeFunction.java:26)
~[apache-cassandra-3.10.jar:3.10]
> 	at org.apache.cassandra.db.transform.BasePartitions.hasNext(BasePartitions.java:96)
~[apache-cassandra-3.10.jar:3.10]
> 	at org.apache.cassandra.cql3.statements.SelectStatement.process(SelectStatement.java:755)
~[apache-cassandra-3.10.jar:3.10]
> 	at org.apache.cassandra.cql3.statements.SelectStatement.process(SelectStatement.java:446)
~[apache-cassandra-3.10.jar:3.10]
> 	at org.apache.cassandra.cql3.UntypedResultSet$FromPager$1.computeNext(UntypedResultSet.java:193)
~[apache-cassandra-3.10.jar:3.10]
> 	at org.apache.cassandra.cql3.UntypedResultSet$FromPager$1.computeNext(UntypedResultSet.java:179)
~[apache-cassandra-3.10.jar:3.10]
> 	at org.apache.cassandra.utils.AbstractIterator.hasNext(AbstractIterator.java:47) ~[apache-cassandra-3.10.jar:3.10]
> 	at org.apache.cassandra.batchlog.BatchlogManager.processBatchlogEntries(BatchlogManager.java:233)
~[apache-cassandra-3.10.jar:3.10]
> 	at org.apache.cassandra.batchlog.BatchlogManager.replayFailedBatches(BatchlogManager.java:209)
~[apache-cassandra-3.10.jar:3.10]
> 	at org.apache.cassandra.concurrent.DebuggableScheduledThreadPoolExecutor$UncomplainingRunnable.run(DebuggableScheduledThreadPoolExecutor.java:118)
~[apache-cassandra-3.10.jar:3.10]
> 	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_66]
> 	at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) [na:1.8.0_66]
> 	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
[na:1.8.0_66]
> 	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
[na:1.8.0_66]
> 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_66]
> 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_66]
> 	at org.apache.cassandra.concurrent.NamedThreadFactory.lambda$threadLocalDeallocator$0(NamedThreadFactory.java:79)
[apache-cassandra-3.10.jar:3.10]
> 	at java.lang.Thread.run(Thread.java:745) ~[na:1.8.0_66]
> Caused by: java.io.IOException: Corrupt value length 355151036 encountered, as it exceeds
the maximum of 268435456, which is set via max_value_size_in_mb in cassandra.yaml
> 	at org.apache.cassandra.db.marshal.AbstractType.readValue(AbstractType.java:428) ~[apache-cassandra-3.10.jar:3.10]
> 	at org.apache.cassandra.db.rows.Cell$Serializer.deserialize(Cell.java:245) ~[apache-cassandra-3.10.jar:3.10]
> 	at org.apache.cassandra.db.rows.UnfilteredSerializer.readComplexColumn(UnfilteredSerializer.java:636)
~[apache-cassandra-3.10.jar:3.10]
> 	at org.apache.cassandra.db.rows.UnfilteredSerializer.lambda$deserializeRowBody$1(UnfilteredSerializer.java:577)
~[apache-cassandra-3.10.jar:3.10]
> 	at org.apache.cassandra.utils.btree.BTree.applyForwards(BTree.java:1222) ~[apache-cassandra-3.10.jar:3.10]
> 	at org.apache.cassandra.utils.btree.BTree.apply(BTree.java:1177) ~[apache-cassandra-3.10.jar:3.10]
> 	at org.apache.cassandra.db.Columns.apply(Columns.java:377) ~[apache-cassandra-3.10.jar:3.10]
> 	at org.apache.cassandra.db.rows.UnfilteredSerializer.deserializeRowBody(UnfilteredSerializer.java:571)
~[apache-cassandra-3.10.jar:3.10]
> 	at org.apache.cassandra.db.UnfilteredDeserializer$CurrentDeserializer.readNext(UnfilteredDeserializer.java:211)
~[apache-cassandra-3.10.jar:3.10]
> 	at org.apache.cassandra.db.columniterator.SSTableIterator$ForwardReader.computeNext(SSTableIterator.java:144)
~[apache-cassandra-3.10.jar:3.10]
> 	at org.apache.cassandra.db.columniterator.SSTableIterator$ForwardReader.hasNextInternal(SSTableIterator.java:168)
~[apache-cassandra-3.10.jar:3.10]
> 	at org.apache.cassandra.db.columniterator.AbstractSSTableIterator$Reader.hasNext(AbstractSSTableIterator.java:382)
~[apache-cassandra-3.10.jar:3.10]
> {code}



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org


Mime
View raw message