Cassandra连接器Apache Spark：本地类不兼容
我试图使用Cassandra Spark连接器将rdd与Cassandra表连接起来：
samplerdd.joinWithCassandraTable(keyspace, CassandraParams.table)
.on(SomeColumns(t.date as a.date,
t.key as a.key)
它在独立模式下工作，但当我在集群模式下执行时，我会得到以下错误：
Job aborted due to stage failure: Task 6 in stage 0.0 failed 4 times, most recent failure: Lost task 6.3 in stage 0.0 (TID 20, 10.10.10.51): java.io.InvalidClassException: com.datastax.spark.connector.rdd.CassandraJoinRDD; local class incompatible: stream classdesc serialVersionUID = 6155891939893411978, local class serialVersionUID = 1245204129865863681
会发生什么事？
共有1个答案
终于解决了。将cassandra-driver-core dependency更新到3.0.0，就可以工作了。-Manuel Valero刚才编辑
-
C：\用户\跨度t 2\下载\apache-cassandra-3.11.5\bin 启动 Cassandra 服务器 C：\用户\跨度t 2\下载\apache-cassandra-3.11.5\bin 连接错误：（'无法连接到任何服务器'，{'127.0.0.1'：错误（10061，"尝试连接到[（'127.0.0.1'，9042）]。最后一个错误：无法进行连接，因为目标机器主动拒绝它"）}）
-
> 我在Linux机器上安装了Spark。版本为spark-1.6.2-bin-hadoop2.6.tgz. 然后使用。/sbin/start-all.sh启动Spark 我尝试在Eclipse中运行javaWordCount.java示例。但总是失败。有人能帮我吗？ 例外情况如下：
-
问题内容： 我创建客户端和服务器，然后在添加客户端类的序列化的目的，然后简单地刚走到客户在我的硬盘驱动器的文件夹，并将其粘贴到服务器correponding位置，都和分别。 它在我自己的笔记本电脑上运行良好，但是当我想在其他系统上继续工作时，当我打开项目文件夹并且客户端尝试连接到服务器后，出现以下错误： 到底是怎么回事？是因为我使用旧版本的IDE运行程序吗？ 问题答案： 如果一个类未在代码中显式定
-
Presto与Cassandra/ScylLadb的默认连接数是多少？如何设置此属性？谢谢
-
**dataframe2:从另一个来源获得的键的Dataframe（这些键是上表中ID列的分区键）-此表中不同键的数量约为0.15万** 现在，此代码总是导致“com.datastax.oss.driver.api.core.servererrors.ReadFailureException：在一致性LOCAL_ONE读取查询期间Cassandra失败（需要1个响应，但只有0个副本响应，1个失败）