使用SStableloader从不同的Cassandra集群加载Cassandra数据

Question

我有两台运行Cassandra的不同独立机器，我想将数据从一台机器迁移到另一台机器。

因此，根据数据税文档，我首先在机器1上拍摄了我的Cassandra集群的快照。

然后，我将数据移动到计算机 2，在那里我尝试使用 sstableloader 导入它。

注意：机器2上的keypsace（open_weather）和tablename（raw_weather_data）已创建，并且与机器1上的相同。

我使用的命令如下所示：

bin/sstableloader -d localhost "path_to_snapshot"/open_weather/raw_weather_data

然后得到以下错误:

Established connection to initial hosts
Opening sstables and calculating sections to stream
For input string: "CompressionInfo.db"
java.lang.NumberFormatException: For input string: "CompressionInfo.db"
    at java.lang.NumberFormatException.forInputString(NumberFormatException.java:65)
    at java.lang.Integer.parseInt(Integer.java:580)
    at java.lang.Integer.parseInt(Integer.java:615)
    at org.apache.cassandra.io.sstable.Descriptor.fromFilename(Descriptor.java:276)
    at org.apache.cassandra.io.sstable.Descriptor.fromFilename(Descriptor.java:235)
    at org.apache.cassandra.io.sstable.Component.fromFilename(Component.java:120)
    at org.apache.cassandra.io.sstable.SSTable.tryComponentFromFilename(SSTable.java:160)
    at org.apache.cassandra.io.sstable.SSTableLoader$1.accept(SSTableLoader.java:84)
    at java.io.File.list(File.java:1161)
    at org.apache.cassandra.io.sstable.SSTableLoader.openSSTables(SSTableLoader.java:78)
    at org.apache.cassandra.io.sstable.SSTableLoader.stream(SSTableLoader.java:162)
    at org.apache.cassandra.tools.BulkLoader.main(BulkLoader.java:106)

不幸的是我不知道为什么？

我不确定它是否与该问题有关，但不知何故，与我在机器 1 上已有的 *.db 文件相比，我的 *.db 文件的名称相当“奇怪”。

*.来自计算机1的db文件：

la-53-big-CompressionInfo.db
la-53-big-Data.db
...
la-54-big-CompressionInfo.db
...

*计算机 2 中的.db文件：

open_weather-raw_weather_data-ka-5-CompressionInfo.db
open_weather-raw_weather_data-ka-5-Data.db

我错过了什么？任何帮助都将不胜感激。我也愿意接受任何其他建议。COPY命令很可能无法工作，因为据我所知，它仅限于99999999行。

附言：我不想创建一个太大的帖子，但如果你需要任何进一步的信息来帮助我，请告诉我。

编辑：请注意，我在独立模式下使用Cassandra。

EDIT2：在我的目标机器（机器 2.1.4）上安装相同的版本 2.1.4 后，我仍然收到所有相同的错误。使用 SSTableLoader，我仍然会收到上述错误，并且手动复制文件（如 LHWizard 所述），在再次启动 Cassandra 并执行 SELECT 命令后，我仍然得到空表。

关于初始令牌，如果我在机器1上执行节点环，我会得到一个巨大的令牌列表。我不知道该如何处理这些令牌？

Answer 1

您的数据已经以快照（或备份）的形式存在，我过去所做的如下：

< li >在恢复节点上安装相同版本的Cassandra < li >在恢复节点上编辑cassandra.yaml确保cluster_name和snitch相同。 < li >编辑种子:列表和原始节点中已更改的任何其他属性。 < li >使用cqlsh DESC密钥空间从原始节点获取架构。 < li >在恢复节点上启动cassandra并导入模式。(步骤6

您不需要批量导入数据，如果您使用的是相同版本的cassandra，它已经是正确的格式，尽管您在最初的问题中没有指定。