我有一个表,其结构大致如下->
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修复,但问题仍然存在
任何帮助都将不胜感激。谢谢
1条答案
按热度按时间j8ag8udp1#
如果表模式发生更改,spark元存储不会自动刷新模式更改,因此使用
DROP TABLE
命令,然后运行SHOW TABLES
. 将自动创建具有最新架构的新表。这不会改变Cassandra的数据。