org.apache.cassandra.serializers.MarshalException cassandra 2.2.4 异常
org.apache.cassandra.serializers.MarshalException exception in cassandra 2.2.4
我们正在致力于 MySQL 到 Cassandra 的数据迁移。我们将 MySQL 数据转储为 CSV 格式并将其转换为 Cassandra CSV 并使用编码 UTF-8。当我们导入 Cassandra CSV 时，它适用于一个集群。但是对于相同的 CSV 文件，它会在另一个集群中针对相同的 Cassandra 版本 (2.2.4)
抛出以下异常
message="org.apache.cassandra.serializers.MarshalException: Invalid UTF-8 bytes 56bc71d9">
Aborting import at record #5. Previously inserted records are still present, and some records after that may be present as well.
一直显示不同记录的异常。记录编号和字节值不一致。
我们使用以下命令导入 CSV 文件
copy <TABLE> FROM <FILE> with DELIMITER = '\t' AND NULL = 'NULL' AND QUOTE = '\"' AND ESCAPE = '\';
我们检查了一些解决方案，但大多数都建议使用 'ASSUME' 命令。由于我们使用的是 Cassandra 2.2.4，因此我们没有 Cassandra-Cli 来检查命令。
是否有任何检查问题的建议或此问题可能发生的任何可能情况。
cassandra lucene index 2.2.4.1 中有一个问题，我已提交。
他们已经解决了。
只需更新您的 lucene 索引代码
classcom.stratio.cassandra.lucene.service.RegularCellsMapper
在方法中 Columns columns(ColumnFamily columnFamily)
在for (Cell cell : columnFamily) {
后添加以下代码
if (!cell.isLive()) {
continue;
}
我们正在致力于 MySQL 到 Cassandra 的数据迁移。我们将 MySQL 数据转储为 CSV 格式并将其转换为 Cassandra CSV 并使用编码 UTF-8。当我们导入 Cassandra CSV 时，它适用于一个集群。但是对于相同的 CSV 文件，它会在另一个集群中针对相同的 Cassandra 版本 (2.2.4)
抛出以下异常message="org.apache.cassandra.serializers.MarshalException: Invalid UTF-8 bytes 56bc71d9"> Aborting import at record #5. Previously inserted records are still present, and some records after that may be present as well.
一直显示不同记录的异常。记录编号和字节值不一致。
我们使用以下命令导入 CSV 文件
copy <TABLE> FROM <FILE> with DELIMITER = '\t' AND NULL = 'NULL' AND QUOTE = '\"' AND ESCAPE = '\';
我们检查了一些解决方案，但大多数都建议使用 'ASSUME' 命令。由于我们使用的是 Cassandra 2.2.4，因此我们没有 Cassandra-Cli 来检查命令。
是否有任何检查问题的建议或此问题可能发生的任何可能情况。
cassandra lucene index 2.2.4.1 中有一个问题，我已提交。
他们已经解决了。
只需更新您的 lucene 索引代码
classcom.stratio.cassandra.lucene.service.RegularCellsMapper
在方法中 Columns columns(ColumnFamily columnFamily)
在for (Cell cell : columnFamily) {
if (!cell.isLive()) {
continue;
}