CassandraSqlContext вставить в таблицу таблицы cassandra невозможно вставить все строки в cassandra DB

Question

Я пытаюсь вставить агрегированные значения в cassandra CF с помощью CassandraSQLContext.

Вот пример кода.

val cc = new CassandraSQLContext(sc) 
cc.sql("insert into table xxxx select * from yyyy") 

Здесь xxxx должен получить 63000 строк от yyyy CF. Но в моем случае выше команда вставляет только половину записей в xxxx CF.

Я хотел бы знать, есть ли какие-либо настройки для обработки этого в datastax? или с SPARK?

Answer 1

Удаленный способ отладки вашего кода cassandra заключается в использовании командной строки cqlsh. Вы можете просто запустить «вставить в таблицу xxxx select * from yyyy» в командной строке cqlsh, возможно, какое-то сообщение об ошибке, если это не удастся. Тогда вы могли бы знать, как это сделать.