我正在尝试在我的集群上部署cassandra datastax企业版4.5.1,我总是得到java.lang.AssertionError,日志如下:
INFO [main] 2014-10-13 069161/ddata/data/system/compaction_history/system-compaction_history-jb-4349; partitioner org.apache.cassandra.dht.RandomPartitionerdoes not match
我正在寻找在每个分区循环中保存整个Dataframe到Cassandra。我知道我可以在foreachpartition中获取Cassandra连接器,并使用以下代码在cassandra上执行CRUD语句: val conf: SparkConf = new SparkConf(true).set("spark.cassandra</em