我已成功下载此连接器: 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
除了错误提示的“寻找另一个连接器”之外,还有其他想法吗?事实上,这是一些专业人士建议我使用的连接器,因此我认为它可能是其他东西。
谢谢!
1条答案
按热度按时间vlju58qv1#
我的问题解决了,我不得不下载:
--包裹com.datasax。spark:spark-cassandra-connector_2.12:2.5.1
哪个是我的scala版本2.12.10的正确连接器
谢谢大家的支持!