2

1 つのノードでコンパクトなジョブを実行すると、次の例外がスローされます。

エラー [CompactionExecutor:116922] 2016-04-07 12:51:17,291 CassandraDaemon.java:153 - スレッドの例外 Thread[CompactionExecutor:116922,1,main]
org.apache.cassandra.io.sstable.CorruptSSTableException: org.apache.cassandra.io.compress.CorruptBlockException: (/data1/data/cassandra_uc_log/log_user-2fdda2a03a7f11e58156c78e55b68188/cassandra_uc_log-log_user-ka-7611-Data.db): 破損l の 602529 でチャンクが検出されました
長さ12126。
    org.apache.cassandra.io.compress.CompressedRandomAccessReader.reBuffer(CompressedRandomAccessReader.java:92) で ~[apache-cassandra-2.1.2.jar:2.1.2]
    org.apache.cassandra.io.compress.CompressedThrottledReader.reBuffer(CompressedThrottledReader.java:41) で ~[apache-cassandra-2.1.2.jar:2.1.2]
    org.apache.cassandra.io.util.RandomAccessReader.read(RandomAccessReader.java:326) で ~[apache-cassandra-2.1.2.jar:2.1.2]
    java.io.RandomAccessFile.readFully(RandomAccessFile.java:444) で ~[na:1.7.0_60]
    java.io.RandomAccessFile.readFully(RandomAccessFile.java:424) で ~[na:1.7.0_60]
    org.apache.cassandra.io.util.RandomAccessReader.readBytes(RandomAccessReader.java:351) で ~[apache-cassandra-2.1.2.jar:2.1.2]
    org.apache.cassandra.utils.ByteBufferUtil.read(ByteBufferUtil.java:348) で ~[apache-cassandra-2.1.2.jar:2.1.2]
    org.apache.cassandra.utils.ByteBufferUtil.readWithLength(ByteBufferUtil.java:311) で ~[apache-cassandra-2.1.2.jar:2.1.2]
    org.apache.cassandra.db.ColumnSerializer.deserializeColumnBody(ColumnSerializer.java:132) ~[apache-cassandra-2.1.2.jar:2.1.2] で
    org.apache.cassandra.db.OnDiskAtom$Serializer.deserializeFromSSTable(OnDiskAtom.java:86) で ~[apache-cassandra-2.1.2.jar:2.1.2]
    org.apache.cassandra.db.AbstractCell$1.computeNext(AbstractCell.java:52) で ~[apache-cassandra-2.1.2.jar:2.1.2]
    org.apache.cassandra.db.AbstractCell$1.computeNext(AbstractCell.java:46) で ~[apache-cassandra-2.1.2.jar:2.1.2]
    com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:143) で ~[グアバ-16.0.jar:na]
    com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:138) で ~[グアバ-16.0.jar:na]
    org.apache.cassandra.io.sstable.SSTableIdentityIterator.hasNext(SSTableIdentityIterator.java:116) で ~[apache-cassandra-2.1.2.jar:2.1.2]
    org.apache.cassandra.utils.MergeIterator$Candidate.advance(MergeIterator.java:146) で ~[apache-cassandra-2.1.2.jar:2.1.2]
    org.apache.cassandra.utils.MergeIterator$ManyToOne.advance(MergeIterator.java:125) で ~[apache-cassandra-2.1.2.jar:2.1.2]
    org.apache.cassandra.utils.MergeIterator$ManyToOne.computeNext(MergeIterator.java:99) で ~[apache-cassandra-2.1.2.jar:2.1.2]
    com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:143) で ~[グアバ-16.0.jar:na]
    com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:138) で ~[グアバ-16.0.jar:na]
    com.google.common.collect.Iterators$7.computeNext(Iterators.java:645) で ~[グアバ-16.0.jar:na]
    com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:143) で ~[グアバ-16.0.jar:na]
    com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:138) で ~[グアバ-16.0.jar:na]
    org.apache.cassandra.db.ColumnIndex$Builder.buildForCompaction(ColumnIndex.java:165) で ~[apache-cassandra-2.1.2.jar:2.1.2]
    org.apache.cassandra.db.compaction.LazilyCompactedRow.write(LazilyCompactedRow.java:110) で ~[apache-cassandra-2.1.2.jar:2.1.2]
    org.apache.cassandra.io.sstable.SSTableWriter.append(SSTableWriter.java:200) で ~[apache-cassandra-2.1.2.jar:2.1.2]
    org.apache.cassandra.io.sstable.SSTableRewriter.append(SSTableRewriter.java:115) で ~[apache-cassandra-2.1.2.jar:2.1.2]
    org.apache.cassandra.db.compaction.CompactionTask.runWith(CompactionTask.java:183) で ~[apache-cassandra-2.1.2.jar:2.1.2]
    org.apache.cassandra.io.util.DiskAwareRunnable.runMayThrow(DiskAwareRunnable.java:48) で ~[apache-cassandra-2.1.2.jar:2.1.2]
    org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:28) で ~[apache-cassandra-2.1.2.jar:2.1.2]
    org.apache.cassandra.db.compaction.CompactionTask.executeInternal(CompactionTask.java:75) ~[apache-cassandra-2.1.2.jar:2.1.2] で
    org.apache.cassandra.db.compaction.AbstractCompactionTask.execute (AbstractCompactionTask.java:59) で ~[apache-cassandra-2.1.2.jar:2.1.2]
    org.apache.cassandra.db.compaction.CompactionManager$BackgroundCompactionTask.run(CompactionManager.java:232) ~[apache-cassandra-2.1.2.jar:2.1.2] で
    java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471) ~[na:1.7.0_60] で
    java.util.concurrent.FutureTask.run(FutureTask.java:262) で ~[na:1.7.0_60]
    java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) で ~[na:1.7.0_60]
    java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) [na:1.7.0_60] で
    java.lang.Thread.run(Thread.java:745) [na:1.7.0_60] で
原因: org.apache.cassandra.io.compress.CorruptBlockException: (/data1/data/cassandra_uc_log/log_user-2fdda2a03a7f11e58156c78e55b68188/cassandra_uc_log-log_user-ka-7611-Data.db): 破損が検出されました、長さ 12126 の 602529 のチャンク。
    org.apache.cassandra.io.compress.CompressedRandomAccessReader.decompressChunk (CompressedRandomAccessReader.java:112) で ~[apache-cassandra-2.1.2.jar:2.1.2]
    org.apache.cassandra.io.compress.CompressedRandomAccessReader.reBuffer(CompressedRandomAccessReader.java:88) で ~[apache-cassandra-2.1.2.jar:2.1.2]
    ... 37 個の共通フレームを省略

そのため、sstable cassandra_uc_log-log_user-ka-7611-Data.db を修復するよりも削除しますが、新しい例外がスローされます。

範囲 (-5651751204441903619,-5621122634670931727) の修復セッション f33a4b10-ffb7-11e5-8fe3-31b2e5b5b0b2] がエラー java.io.IOException で失敗しました: スナップショットの作成中に失敗しました。

sstable cassandra_uc_log-log_user-ka-7611-Data.db を修復または再構築するにはどうすればよいですか

4

1 に答える 1

2

残念ながら、ファイルを削除してノードを再起動する必要があります。次回は、破損した sstable を配置して nodetool Scrub を実行することもできます。

Cassandra のバージョンについては言及していませんが、Cassandra 2.1 以降でインクリメンタル リペアを使用していると仮定すると、sstable が既にリペア済みの状態である場合に備えて、完全なリペアを行う必要がある場合もあります。

于 2016-04-11T12:16:53.297 に答える