Cassandra SStableLoader Streaming Error Broken pipe

Question

我正在尝试使用 SSTableLoader 将表从 Cassandra 2.1 集群迁移到 Cassandra 3.11，虽然成功加载了一些 SStable，但我一直遇到其他奇怪的错误。 我试图重复加载相同的 SSTables，有时我得到一个通用的

java.util.concurrent.ExecutionException： org.apache.cassandra.streaming.StreamException：流失败

其他时间

org.apache.cassandra.io.FSReadError: java.io.IOException: Broken pipe

但是，如果我检查 system.log，我总是会发现这个错误：

java.lang.IllegalArgumentException：在中找不到列名组件 单元格名称

尝试搜索上述错误，未找到任何有用的详细信息。

我在 2.x 集群中的表上尝试了 nodetool 修复，但几个小时后它看起来仍然没有完成。我会尝试使用 nodetool scrub 但不确定这是否会导致数据丢失。

Answer 1

问题在于 Cassandra 3.0 中的 sstable 格式发生了变化，因此您不能只将 2.1 格式的 sstable 流式传输到 3.x 节点作为 sstable 格式。

官方（更好的）方法是，您首先需要将节点升级到更新的 C* 版本，然后运行 ​​nodetool upgradesstables -a。