0

例如下面是我的代码：

spark = SparkSession.builder.appName('SparkCassandraApp')\
    .config('spark.cassandra.connection.host', 'xx.xx.xx.xx') \
    .config('spark.cassandra.connection.port', '9042') \
    .config("spark.cassandra.auth.username","username")\
    .config("spark.cassandra.auth.password","password")\
    .getOrCreate()
df = spark.read.format("org.apache.spark.sql.cassandra").option("table","local").option( "keyspace","system").load().select('host_id')
df.show()

出现以下错误：

错误executor.Executor：阶段0.0（TID 0）中任务0.0中的异常java.io.IOException：准备SELECT“host_id”FROM“system”期间出现异常。“local”WHERE token（“key”）<？允许过滤：org/apache/spark/sql/catalyst/package$ScalaReflectionLock$ at com.datastax.spark.connector.rdd.CassandraTableScanRDD.createStatement(CassandraTableScanRDD.scala:323)

我在用着

火花版本：2.4.6

斯卡拉版本：2.11.12

spark -cassandra-connector spark-cassandra-connector_2.11-2.0.5-yb-2.jar

4

1 回答 1

2

对于 Spark 2.4.x，您需要使用 Spark Cassandra Connector 2.4.3 或者更好的是新发布的 2.5.0。Spark Cassandra 连接器仅与 Spark 2.0-2.2 兼容。请参阅兼容性矩阵。

请参阅有关如何将 SCC 2.5.0 与 pyspark 一起使用的说明。

于 2020-07-02T09:43:29.687 回答