DSE Analytics Spark中无效的列名称错误

Question

我有一个表，其结构大致如下 ->

CREATE TABLE keyspace_name.table_name (
  id text PRIMARY KEY,
  type text,
  bool_yn boolean,
  created_ts timestamp,
  modified_ts timestamp
)

最近我在表 ->

中添加了新列

alter table keyspace_name.table_name first_name text;

，当我从CQLSH的表中查询给定列时，它给了我结果。例如

select first_name from keyspace_name.table_name limit 10;

但是，如果我尝试在dse spark-sql

中执行相同的查询

它给我以下错误。

查询中的错误：无法解析" first_name"给定输入列：[ID，type，bool_yn，create_ts，modified_ts];

我不知道Spark-SQL有什么问题。我尝试了Nodetool维修，但问题仍然存在

任何帮助将不胜感激。谢谢

Answer 1

如果表格架构更改，则火花元时间不会自动刷新模式，因此用DROP TABLE命令手动从Spark SQL中移除旧表，然后运行SHOW TABLES。具有最新模式的新表将自动创建。这不会更改Cassandra中的数据。