Pyspark (spark 1.6.x) ImportError: 无法导入名称 Py4JJavaError

Posted 2023-04-15

【中文标题】Pyspark (spark 1.6.x) ImportError: 无法导入名称 Py4JJavaError

【英文标题】：Pyspark (spark 1.6.x) ImportError: cannot import name Py4JJavaError

【发布时间】：2016-07-21 15:40:42

【问题描述】：

我正在使用 Apache-Spark (pyspark)，一切正常。现在，我正在尝试加载可能存在或不存在的数据。因此，我正在尝试捕获 Py4JJavaError 并尝试按如下方式导入它：

from py4j.java_gateway import Py4JJavaError
ImportError: cannot import name Py4JJavaError

当我解压这个文件时： /usr/local/Cellar/apache-spark/1.6.2/python/lib/py4j-0.9-src.zip

并检查此文件： java_gateway.py

我找不到Py4JJavaError。

我做错了什么？我应该使用其他任何地方/路径吗？

【参考方案1】：

试试from py4j.protocol import Py4JJavaError。