Cassandra COPY 命令失败答案

【问题标题】：Cassandra COPY command failingCassandra COPY 命令失败
【发布时间】：2017-09-06 14:36:20
【问题描述】：

当我尝试使用 COPY 命令将由 ; 分隔的 csv 文件的数据插入到 cassandra 表中时，我遇到了以下错误：

ErrorMessage code=000a [Protocol error] message="Cannot decode string as UTF8:

'e23fa22f2[...truncated by author...]6f742c2e2729';

java.nio.charset.MalformedInputException: Input length = 1"> Aborting
import at record #252. Previously inserted records are still present,
and some records after that may be present as well.

我的 CQL 查询是

copy retail.products_by_id (product_id,product_name,price,supplier_id,supplier_name,category_id,category_name,release_date,description) FROM '/home/centos/retail_data/prod1_new.txt' WITH DELIMITER = ';' AND HEADER=true;

不知道怎么回事。数据有问题吗？我的文件大小为 20MB 需要有关如何解决此问题的建议

【问题讨论】：

标签： java utf-8 cassandra data-modeling nosql

【解决方案1】：

/home/centos/retail_data/prod1_new.txt 中的第 252 条记录无效。应该能够在编辑器中打开它并转到该行查看它。

【讨论】：

【解决方案2】：

在一个好的编辑器中打开您的 CSV，并深入查看数据的第 252 行（从标题之后开始计数）。有或前面的一行将是一个错误 - 和/或您的数据不是文本而是一个 blob。

【讨论】：