dse analytics spark中出现无效列名错误

pieyvz9o  于 2021-06-10  发布在  Cassandra
关注(0)|答案(1)|浏览(354)

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

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;

但是如果我尝试在dsesparksql中执行相同的查询
它给了我以下的错误。
查询出错:无法解析' first_name '给定的输入列:[id,type,bool_yn,created_ts,modified_ts];
我不知道spark sql有什么问题。我试过nodetool修复,但问题仍然存在
任何帮助都将不胜感激。谢谢

j8ag8udp

j8ag8udp1#

如果表模式发生更改,spark元存储不会自动刷新模式更改,因此使用 DROP TABLE 命令,然后运行 SHOW TABLES . 将自动创建具有最新架构的新表。这不会改变Cassandra的数据。

相关问题