Cada vez que trato de consultar mi db casandra de esta manera:
sc.parallelize(keys).repartitionByCassandraReplica("keyspace","mytable")
.joinWithCassandraTable("keyspace", "mytable")
.select("whatever")
mi trabajo de chispa se colgará indefinidamente en esta línea en los registros:
INFO CassandraConnector: Disconnected from Cassandra cluster: mycluster
Respuestas
0 para la respuesta № 1Resulta que el problema fue causado de alguna manera por el hecho de que estaba ejecutando cassandra a través de CCM. Cuando instalé y ejecuté Cassandra directamente, el problema desapareció.