Спарк зависает при подключении к Кассандре с repartitionByCassandraReplicator

Question

Всякий раз, когда я пытаюсь запросить мой Кассандры дб, как это:

sc.parallelize(keys).repartitionByCassandraReplica("keyspace","mytable") 
     .joinWithCassandraTable("keyspace", "mytable") 
     .select("whatever") 

моя искра работа будет зависнуть на этой линии в журналах:

INFO CassandraConnector: Disconnected from Cassandra cluster: mycluster 

Answer 1

Оказывается, проблема была вызвана тем, что я запускал cassandra через CCM. Когда я установил и запустил cassandra напрямую, проблема исчезла.