Cassandra：流错误 - 压缩长度不匹配答案

【问题标题】：Cassandra: Streaming error - Compressed lengths mismatchCassandra：流错误 - 压缩长度不匹配
【发布时间】：2020-03-24 04:44:04
【问题描述】：

我正在使用 sstableloader 在 Cassandra 中恢复快照。集群中某些节点的 sstable 加载过程失败并出现错误

sstableloader 命令出错：

Streaming to the following hosts failed:
[/10.x.x.x, /10.x.x.x, /10.x.x.x]
java.util.concurrent.ExecutionException: org.apache.cassandra.streaming.StreamException: Stream failed
        at com.google.common.util.concurrent.AbstractFuture$Sync.getValue(AbstractFuture.java:299)
        at com.google.common.util.concurrent.AbstractFuture$Sync.get(AbstractFuture.java:286)
        at com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:116)
        at org.apache.cassandra.tools.BulkLoader.load(BulkLoader.java:98)
        at org.apache.cassandra.tools.BulkLoader.main(BulkLoader.java:48)
Caused by: org.apache.cassandra.streaming.StreamException: Stream failed

一个失败节点的日志错误：

 [Stream #bac90a-32] Streaming error occurred on session with peer 10.x.x.x
java.io.IOException: Compressed lengths mismatch
        at org.apache.cassandra.io.compress.LZ4Compressor.uncompress(LZ4Compressor.java:147) ~[apache-cassandra-3.11.4.jar:3.11.4]
        at org.apache.cassandra.streaming.compress.CompressedInputStream.decompress(CompressedInputStream.java:163) ~[apache-cassandra-3.11.4.jar:3.11.4]
        at org.apache.cassandra.streaming.compress.CompressedInputStream.decompressNextChunk(CompressedInputStream.java:109) ~[apache-cassandra-3.11.4.jar:3.11.4]
        at org.apache.cassandra.streaming.compress.CompressedInputStream.read(CompressedInputStream.java:121) ~[apache-cassandra-3.11.4.jar:3.11.4]

长度不匹配的可能原因是什么？

【问题讨论】：

标签： cassandra

【解决方案1】：

这通常表示流式传输到节点的 sstable 已损坏。您可以尝试在源节点上运行nodetool scrub，并通过查看system.log 中的清理输出来查看是否发现任何损坏。修复源损坏后，您可以尝试拍摄快照并再次使用 sstableloader 加载它。

您还可以尝试通过在每个表上运行 sstabledump 来确定快照中的哪个 sstable 已损坏。如果您在运行 sstabledump 时遇到同样的错误，您就知道您找到了损坏的文件。您可以删除该文件并尝试加载其余文件。

【讨论】：