如何解决Cassandra连接器在“ load”处出现问题
我成功下载了此连接器: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
除了错误提示“寻找另一个连接器”以外,还有其他想法吗?确实,这是一些专业人士建议我使用的连接器,因此,我认为大多数是其他连接器。
谢谢!
解决方法
我的问题解决了,我必须下载:
-打包com.datastax.spark:spark-cassandra-connector_2.12:2.5.1
这是我的Scala版本的正确连接器:2.12.10
谢谢大家的支持!
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。