Ошибка неверного имени столбца в DSE Analytics Spark - PullRequest
Новая
       50

Ошибка неверного имени столбца в DSE Analytics Spark

0 голосов
/ 01 марта 2019

У меня есть одна таблица, структура которой примерно такова -> 

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, создал_ц, измененный_ц];

Я не знаю, что не так в spark-sql.Я пытался восстановить nodetool, но проблема все еще сохраняется

Любая помощь будет оценена.Спасибо

1 Ответ

0 голосов
/ 12 марта 2019

Если схема таблицы изменяется, метасторное хранилище Spark не обновляет автоматически изменения схемы, поэтому вручную удалите старые таблицы из spark sql с помощью команды DROP TABLE, а затем выполните SHOW TABLES.Новая таблица с последней схемой будет создана автоматически.Это не изменит данные в Кассандре.

...