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

Question

我正在使用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.

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

Answer 1

试试from py4j.protocol import Py4JJavaError.