Py4JError:调用时发生错误None.org.apache.spark.api.python.PythonAccumulatorV2。跟踪:py4j.Py4JException:构造函数org.apache.spark.api.python.PythonAccumulatorV2([classjava.lang.String,类java.lang.Integer,类java.lang.String])不存在
Py4JErrorTraceback (most recent call last) C:\Premi�reEssai\maman.py in <module>() 818 findspark.init() 819 conf = SparkConf().setMaster('local').setAppName('MonEssai') --> 820 sc = SparkContext.getOrCreate(); 821 lines = sc.textFile("file:///PremiéreEssai/ file9.txt") 822 fun = lines.flatMap(listsGraph) C:\Users\hene\AppData\Local\Enthought\Canopy\edm\envs\User\lib\site-packages\pyspark\context.pyc in getOrCreate(cls, conf) 347 with SparkContext._lock: 348 if SparkContext._active_spark_context is None: --> 349 SparkContext(conf=conf or SparkConf()) 350 return SparkContext._active_spark_context 351 C:\Users\hene\AppData\Local\Enthought\Canopy\edm\envs\User\lib\site-packages\pyspark\context.pyc in __init__(self, master, appName, sparkHome, pyFiles, environment, batchSize, serializer, conf, gateway, jsc, profiler_cls) 116 try: 117 self._do_init(master, appName, sparkHome, pyFiles, environment, batchSize, serializer, --> 118 conf, jsc, profiler_cls) 119 except: 120 # If an error occurs, clean up in order to allow future SparkContext creation: C:\Users\hene\AppData\Local\Enthought\Canopy\edm\envs\User\lib\site-packages\pyspark\context.pyc in _do_init(self, master, appName, sparkHome, pyFiles, environment, batchSize, serializer, conf, jsc, profiler_cls) 187 self._accumulatorServer = accumulators._start_update_server(auth_token) 188 (host, port) = self._accumulatorServer.server_address --> 189 self._javaAccumulator = self._jvm.PythonAccumulatorV2(host, port, auth_token) 190 self._jsc.sc().register(self._javaAccumulator) 191 C:\Users\hene\AppData\Local\Enthought\Canopy\edm\envs\User\lib\site-packages\py4j\java_gateway.pyc in __call__(self, *args) 1523 answer = self._gateway_client.send_command(command) 1524 return_value = get_return_value( -> 1525 answer, self._gateway_client, None, self._fqn) 1526 1527 for temp_arg in temp_args: C:\Users\hene\AppData\Local\Enthought\Canopy\edm\envs\User\lib\site-packages\py4j\protocol.pyc in get_return_value(answer, gateway_client, target_id, name) 330 raise Py4JError( 331 "An error occurred while calling {0}{1}{2}. Trace:\n{3}\n". --> 332 format(target_id, ".", name, value)) 333 else: 334 raise Py4JError( 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 exist at 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)
所以,我陷入了该怎么办?
我在Windows以及python和pyspark上安装了Canopy IDE。在执行程序代码时,出现了sparK上下文的问题:findspark.init()conf = SparkConf()。setMaster('local')....