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，created_ts，modified_ts];

我不知道spark-sql有什么问题。我尝试过nodetool修复，但问题仍然存在

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

Answer 1

如果表模式发生更改，Spark Metastore不会自动刷新模式更改，因此使用DROP TABLE命令从spark sql手动删除旧表，然后运行SHOW TABLES。将自动创建具有最新架构的新表。这不会改变Cassandra中的数据。