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

戈帕拉

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

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

马特·梅瑟史密斯(Matt Messersmith)

尝试一下from py4j.protocol import Py4JJavaError

本文收集自互联网,转载请注明来源。

如有侵权,请联系 [email protected] 删除。

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章

pySpark Reduce抛出Py4JJavaError

在执行PySpark代码时面临Py4JJavaError

Py4JJavaError 中的基本 pyspark 结果

使用count()和first()时,iPython Notebook中的PySpark引发Py4JJavaError

PySpark python问题:Py4JJavaError:调用o48.showString时发生错误

將 PySpark 數據幀寫入 Parquet 文件時出現 Py4JJavaError

dataframe,spark 2.3.1上的Describe()函数抛出Py4JJavaError

Spark数据框将不显示()-Py4JJavaError:调用o426.showString时发生错误

Py4JJavaError:调用o37.showString时发生错误。Spark和anaconda3

Py4JJavaError:调用o57.sql时发生错误:org.apache.spark.SparkException:作业中止

pyspark:NameError:未定义名称“ spark”

使用PySpark和Kafka,Py4JJavaError进行结构化流传输:调用o70.awaitTermination时发生错误

pyspark ImportError:无法导入名称累加器

ImportError:无法从“ pyspark.sql”导入名称“ HiveContext”

Py4JJavaError:调用o45.load时发生错误。:java.lang.NoClassDefFoundError:org / apache / spark / sql / sources / v2 / StreamWriteSupport

ImportError:无法导入名称pubsub_v1

ImportError:无法从“ neo4j.v1”(/usr/local/lib/python3.7/site-packages/neo4j/v1/__init__.py)导入名称“ CypherError”

Bootstrap 6-4-2-1列

X1 Carbon Gen 6无法进入深度睡眠

JNI_VERSION_1_6 与 JNI_VERSION_1_4

(PY)错误消息:无法导入名称“ pkcs1_15”

ImportError:无法导入名称“ speech_v1p1beta1”

PySpark:无法导入名称“ OneHotEncoderEstimator”

无法将变量传递给pyspark中的Spark SQL查询

如何在JavaScript中[1,2] + [4,5,6] [1] = 1,25

有人可以解释为什么此代码返回6 6 6 6 6而不是1 2 3 4 5

Android无法解析的日期:2017年1月6日

电池X1C6短电池Ubuntu 18.04

echo [9876543210]显示1 4 5 6 ...为什么?