【问题标题】:pyspark not connecting to local cassandrapyspark 未连接到本地 cassandra
【发布时间】:2021-09-12 14:45:13
【问题描述】:

我正在尝试使用 pyspark 从 cassandra 表中读取数据。 我使用的代码如下所示

import pandas as pd
import numpy as np
from pyspark import *
import os
from pyspark.sql import SQLContext

os.environ['PYSPARK_SUBMIT_ARGS'] = '--packages com.datastax.spark:spark-cassandra-connector_2.12:3.0.0 --conf spark.cassandra.connection.host=127.0.0.1 pyspark-shell'
conf = SparkConf().set("spark.cassandra.connection.host", "127.0.0.1").set("spark.cassandra.connection.port", "9042").setAppName("Sentinel").setMaster("spark://Suraj-Vashistha-Laptop:7077")
sc = SparkContext(conf=conf)
sqlContext = SQLContext(sc)

table_df = sqlContext.read\
        .format("org.apache.spark.sql.cassandra")\
        .options(table='movies', keyspace='practice')\
        .load()

我什至使用了 spark-cassandra-connector 版本 3.0.0 ,python 3

Spark 已启动并运行,如下所示:

如上所示,有一个 spark 实例已初始化并处于等待状态。 它在默认 localhost:8080 中运行

Cassandra 也已启动并运行:

Cassandra 也在 localhost:9042 上运行

所以两者都在本地机器上。 尽管如此,我仍然无法连接和运行代码。 我收到以下错误:

Py4JJavaError: An error occurred while calling o36.load.
: java.io.IOException: Failed to open native connection to Cassandra at {127.0.0.1:9042} :: Could not reach any contact point, make sure you've provided valid addresses 

关于堆栈溢出有类似的问题,但他们都是 2 或 3 岁以上,没有一个答案对我有用。因此,我再次要求这个新观点。

我的 cassandra 版本详细信息是 [cqlsh 6.0.0 |卡桑德拉 4.0 | CQL 规范 3.4.5 |原生协议 v5]

我只保留最新版本的所有内容。

所以,我无法弄清楚出了什么问题,因为一切似乎都在运行,但错误说无法到达任何联系点。出了什么问题??

编辑: 我最近能够使用完全相同的代码并连接到托管在不同 IP (10.160.0.2) 上的 cassandra 数据库,但对于 localhost 它不起作用。

EDIT2: 我在 spark-shell 上逐行执行相同的代码(我有 localhost 而不是第一个编辑 IP 的代码)。我将它作为 spark-shell --packages datastax 的 cassandra 连接器启动。 因此,我观察到在到达 .load() 或 .show() 或 .first() 之前一切正常。 我可以执行以下操作

val conf = new SparkConf(true).set("spark.cassandra.connection.host", cassandraHost)
val sc = new SparkContext("spark://" + sparkMasterHost + ":7077", "example", conf)
val rdd = sc.cassandraTable(keyspace, table)

此时输出(我放在下一行)是一个创建的对象,到目前为止没有发现错误

rdd: com.datastax.spark.connector.rdd.CassandraTableScanRDD[com.datastax.spark.connector.CassandraRow] = CassandraTableScanRDD[0] at RDD at CassandraRDD.scala:18

当我尝试执行 rdd.show() 或 rdd.first() 或 rdd.collect() 时,接下来会发生问题。 而且我得到了我在上面的问题中发布的相同错误(无法打开本地连接,无法到达任何联系点)。

【问题讨论】:

  • 你的 cassandra 是否配置了 SSL?
  • 不,因为它只是 localhost 我没有配置 SSL。有要求吗?
  • 没有。这不是一个要求。我怀疑它可能是配置错误...
  • 好的,正如我在编辑中所说的那样。它适用于不同的 IP,但不适用于 localhost。有点奇怪的原因,因为除了放新 IP 之外我没有改变任何东西。

标签: python pyspark cassandra datastax spark-cassandra-connector


【解决方案1】:

此异常表明您很可能遇到网络连接问题:

java.io.IOException: Failed to open native connection to Cassandra at {127.0.0.1:9042} :: \
  Could not reach any contact point, make sure you've provided valid addresses

您的 pyspark 应用无法连接到端口 9042 上的 localhost。检查您是否没有阻止访问 Cassandra 节点的软件防火墙,例如 iptablesfirewalld

要检查的另一件事是您为rpc_address 配置的IP。作为测试的替代方法,将 RPC 地址设置为笔记本电脑的 IP 并重新启动 Cassandra。然后在 pyspark 配置中将 spark.cassandra.connection.host 设置为笔记本电脑的 IP,看看它是否有效。

作为旁注,您在第二次编辑中陈述了这一点:

我将它作为 spark-shell --packages datastax 的 cassandra 连接器启动。因此,我观察到在到达 .load() 或 .show() 或 .first() 之前一切正常。

原因是 Spark 中的评估是惰性的——在调用操作之前不会执行任何操作。在调用 collect() 之类的操作之前,您不会看到任何错误,因为在您的代码中没有执行任何操作。干杯!

【讨论】:

  • .load 无论如何都会尝试获取元数据,因此它需要正常工作的连接
  • 是的,我同意。 :)
  • 您好,感谢您的回复。是的,问题在于 iptables 阻止访问。它现在工作正常。非常感谢。
猜你喜欢
  • 2017-07-16
  • 2017-05-20
  • 2015-09-25
  • 1970-01-01
  • 2014-10-29
  • 2021-11-06
  • 1970-01-01
  • 1970-01-01
  • 2021-05-27
相关资源
最近更新 更多