incubator-cassandra-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jason Wee <peich...@gmail.com>
Subject Re: unable to compact large rows
Date Wed, 24 Jul 2013 18:07:13 GMT
Would it possible to delete this row and reinsert this row? By the way, how
large is that one row?

Jason


On Wed, Jul 24, 2013 at 9:23 AM, Paul Ingalls <paulingalls@gmail.com> wrote:

> I'm getting constant exceptions during compaction of large rows.  In fact,
> I have not seen one work, even starting from an empty DB.  As soon as I
> start pushing in data, when a row hits the large threshold, it fails
> compaction with this type of stack trace:
>
>  INFO [CompactionExecutor:6] 2013-07-24 01:17:53,592
> CompactionController.java (line 156) Compacting large row
> fanzo/tweets_by_id:352567939972603904 (153360688 bytes) incrementally
> ERROR [CompactionExecutor:6] 2013-07-24 01:18:12,496 CassandraDaemon.java
> (line 192) Exception in thread Thread[CompactionExecutor:6,1,main]
> java.lang.AssertionError: incorrect row data size 5722610 written to
> /mnt/datadrive/lib/cassandra/data/fanzo/tweets_by_id/fanzo-tweets_by_id-tmp-ic-1453-Data.db;
> correct is 5767384
>         at
> org.apache.cassandra.io.sstable.SSTableWriter.append(SSTableWriter.java:162)
>         at
> org.apache.cassandra.db.compaction.CompactionTask.runWith(CompactionTask.java:162)
>         at
> org.apache.cassandra.io.util.DiskAwareRunnable.runMayThrow(DiskAwareRunnable.java:48)
>         at
> org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:28)
>         at
> org.apache.cassandra.db.compaction.CompactionTask.executeInternal(CompactionTask.java:58)
>         at
> org.apache.cassandra.db.compaction.AbstractCompactionTask.execute(AbstractCompactionTask.java:60)
>         at
> org.apache.cassandra.db.compaction.CompactionManager$BackgroundCompactionTask.run(CompactionManager.java:211)
>         at
> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
>         at
> java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334)
>         at java.util.concurrent.FutureTask.run(FutureTask.java:166)
>         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:724)
>
> I'm not sure what to do or where to look.  Help…:)
>
> Thanks,
>
> Paul
>
>
>

Mime
View raw message