Я изучаю потоки Spark и пытаясь сохранить свой образец Данные о запасах (только строки, такие как «MSFT: 28.29»), полученные от темы Кафка до Кассандры с использованием искрового потока и разъема Cass
У меня есть 7 узлов кассандры (5 nodes with 32 cores and 32G memory, and 4 nodes with 4 cores and 64G memory) и развернуты искровые рабочие на этом кластере, а мастер искры - в 8th node. И я использов
Я использую Cassandra 2.1.5 (dsc), Spark 1.2.1 с разъемом spark-cassandra 1.2.1. Когда я запускаю работу Спарк (Scala скрипт), я получаю следующее сообщение об ошибке: 16/03/08 10:22:03 INFO DAGSchedu