Cassandra time类型字段解码失败如何导出原有错误数据

方法1：跳过问题字段读取正常数据 #

如果你不需要保留错误写入的starttime字段值，只需要其他字段数据，直接在SELECT语句中显式指定除starttime外的所有字段即可避开解码错误：

-- 替换为你表中除starttime外的实际字段名
SELECT col1, col2, col3 FROM table1;

Cassandra 3.10及以上版本还可以用EXCEPT语法简化语句：

SELECT * EXCEPT (starttime) FROM table1;

方法2：通过blob类型读取starttime原始值 #

如果需要保留starttime写入的原始字符串内容，可以使用CAST函数将time类型强制转为blob读取原始字节，不会触发time类型的解码校验：

-- 读取所有字段，starttime转为blob类型返回原始字节
SELECT CAST(starttime AS BLOB) AS starttime_raw, * EXCEPT (starttime) FROM table1;

拿到blob值后，直接将blob转成UTF-8字符串即可得到之前错误写入的string内容。

方法3：离线导出SSTable获取全量原始数据 #

如果上述CQL操作都无法满足需求，可以直接在Cassandra节点本地用sstable2json工具导出底层SSTable文件的原始数据，完全绕过CQL的类型校验逻辑：

1. 找到table1对应SSTable存储路径，默认路径为${CASSANDRA_HOME}/data/你的键空间名/table1-随机后缀/
2. 在节点本地执行导出命令：

sstable2json /path/to/table1的SSTable文件.db > table1_raw_data.json

导出的JSON文件中包含所有字段的原始存储值，可直接用于后续数据迁移。

迁移注意事项 #

• 操作前先备份原表对应的所有SSTable文件，避免误操作导致数据丢失
• 新表根据业务需求将starttime字段设置为正确的类型（如text或timestamp），校验导出的原始数据格式无误后再执行导入
• 数据迁移完成且校验一致性通过后再清理原有问题表

内容的提问来源于stack exchange，提问作者Ashot