更新时间:2024-02-07 GMT+08:00

使用Spark连接Cassandra失败

问题描述

用户使用Spark连接开源Cassandra,读取数据没问题,但是连接GeminiDB Cassandra就报错。

报错信息如下:

配置详情

如下为用户使用的组件及账号配置详情。

  • 组件配置详情。
    表1 配置详情

    组件名

    版本号

    spark-cassandra-connector

    2.5.1

    spark

    2.5.1

    开源Cassandra

    3.11

    scala

    2.12

  • 用户:user1(rwuser用户创建)

可能原因

  • user1用户无keyspace system查询权限。
  • spark版本问题。

解决方案

  1. 使用rwuser给user1授予keyspace system查询权限。
  2. 使用2.4.1版本的spark-cassandra-connector。