完整報錯如下：
?

2019-05-21 15:19:00 WARN NativeCodeLoader:62 - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable Setting default log level to "WARN". To adjust logging level use sc.setLogLevel(newLevel). For SparkR, use setLogLevel(newLevel). Traceback (most recent call last):File "WordCount.py", line 48, in <module>sc=CreateSparkContext()File "WordCount.py", line 37, in CreateSparkContextspark = SparkSession.builder.appName("Intro").config("spark.master", "local").getOrCreate()File "/home/appleyuchi/.virtualenvs/python2.7/local/lib/python2.7/site-packages/pyspark/sql/session.py", line 173, in getOrCreatesc = SparkContext.getOrCreate(sparkConf)File "/home/appleyuchi/.virtualenvs/python2.7/local/lib/python2.7/site-packages/pyspark/context.py", line 367, in getOrCreateSparkContext(conf=conf or SparkConf())File "/home/appleyuchi/.virtualenvs/python2.7/local/lib/python2.7/site-packages/pyspark/context.py", line 136, in __init__conf, jsc, profiler_cls)File "/home/appleyuchi/.virtualenvs/python2.7/local/lib/python2.7/site-packages/pyspark/context.py", line 207, in _do_initself._javaAccumulator = self._jvm.PythonAccumulatorV2(host, port, auth_token)File "/home/appleyuchi/.virtualenvs/python2.7/local/lib/python2.7/site-packages/py4j/java_gateway.py", line 1525, in __call__answer, self._gateway_client, None, self._fqn)File "/home/appleyuchi/.virtualenvs/python2.7/local/lib/python2.7/site-packages/py4j/protocol.py", line 332, in get_return_valueformat(target_id, ".", name, value)) py4j.protocol.Py4JError: An error occurred while calling None.org.apache.spark.api.python.PythonAccumulatorV2. Trace: py4j.Py4JException: Constructor org.apache.spark.api.python.PythonAccumulatorV2([class java.lang.String, class java.lang.Integer, class java.lang.String]) does not existat py4j.reflection.ReflectionEngine.getConstructor(ReflectionEngine.java:179)at py4j.reflection.ReflectionEngine.getConstructor(ReflectionEngine.java:196)at py4j.Gateway.invoke(Gateway.java:237)at py4j.commands.ConstructorCommand.invokeConstructor(ConstructorCommand.java:80)at py4j.commands.ConstructorCommand.execute(ConstructorCommand.java:69)at py4j.GatewayConnection.run(GatewayConnection.java:238)at java.lang.Thread.run(Thread.java:748)

解決方案如下:
.py文件開頭加入：

# -*- coding: UTF-8 -*- import findspark findspark.init()

?

總結

以上是生活随笔為你收集整理的None.org.apache.spark.api.python.PythonAccumulatorV2的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。