cassandra连接器在“load()处出现问题”

oyxsuwqo  于 2021-05-27  发布在  Spark
关注(0)|答案(1)|浏览(531)

我已成功下载此连接器: com.datastax.spark:spark-cassandra-connector_2.11:2.5.1 当我尝试用这行加载信息时:

data = sparkSession.read.format("org.apache.spark.sql.cassandra").options(table="tbthesis", 
keyspace="test").load()

我得到这个错误:

Exception has occurred: Py4JJavaError
An error occurred while calling o48.load.
: java.lang.ClassNotFoundException: Failed to find data source: org.apache.spark.sql.cassandra. 
Please find packages at http://spark.apache.org/third-party-projects.html

除了错误提示的“寻找另一个连接器”之外,还有其他想法吗?事实上,这是一些专业人士建议我使用的连接器,因此我认为它可能是其他东西。
谢谢!

vlju58qv

vlju58qv1#

我的问题解决了,我不得不下载:
--包裹com.datasax。spark:spark-cassandra-connector_2.12:2.5.1
哪个是我的scala版本2.12.10的正确连接器
谢谢大家的支持!

相关问题