当前位置: 首页 > 知识库问答 >
问题:

Cassandra-Spark集成连接器包发生了什么变化?

宰父君昊
2023-03-14

有人能解释一下DataStax Cassandra-Spark连接器最近的版本历史中发生了什么吗?

共有1个答案

朱保赫
2023-03-14

在您的情况下,这是特定的提交差异:

https://github.com/datastax/spark-cassandra-connector/commit/36AD9CD6C13600144E3E27533587DB926E41AF2E

这就是相关的问题:

 类似资料:
  • 我得到了一个错误:- 线程“main”java.lang.nosuchmethoderror:com.datastax.driver.core.queryoptions.setrefreshnodeintervalmillis(I)lcom/datastax/driver/core/queryoptions;**在com.datastax.spark.connector.cql.defaultCo

  • 同时试图保存一个大字符串到卡桑德拉!谁能帮我弄清楚这个问题: 是什么导致了这个错误以及如何删除它,我的用例是在Cassandra中保存一个非常大的字符串!

  • 注意,这里是每个cassandra分区的限制,而不是每个spark分区的限制(连接器中现有的限制函数支持这一点)。 spark 2.0.1,连接器-2.0.0-M3

  • **dataframe2:从另一个来源获得的键的Dataframe(这些键是上表中ID列的分区键)-此表中不同键的数量约为0.15万** 现在,此代码总是导致“com.datastax.oss.driver.api.core.servererrors.ReadFailureException:在一致性LOCAL_ONE读取查询期间Cassandra失败(需要1个响应,但只有0个副本响应,1个失败)

  • 我试图在卡桑德拉的一小部分数据上运行一个火花工作。我手头有一个键的RDD(分区和集群列),我只想在这些键上运行我的作业。 我在BoundStatementBuilder上收到以下错误:19

  • 问题-无法使用Spark Cassandra连接器1.5.0连接Cassandra 3.0 根据DataStax Spark Cassandra Connector文档,它说Spark Connector 1.5可以从Spark 1.5.0/1.6.0用于Cassandra 3.0。 你能告诉我我是不是漏掉了哪一步? 尝试的方法 在“pom.xml”中添加了单独的番石榴依赖项 提前谢了。