-
1 votesanswersviews
py4j.Py4JException:方法socketTextStream不存在
我是Spark Streaming的新手 . 在PyCharm中使用PySpark我无法通过socketTextStream初始化 . def start_streaming (self): sp = SparkContext('local[2]', 'streamingTest') stream = StreamingContext(sp, 1) **items = st... -
1 votesanswersviews
如何使用`py4j.java_gateway:Error`优雅地完成pyspark单元测试?
如何在测试结束时没有看到这个恼人的错误,优雅地完成pyspark单元测试?似乎python客户端正在失去与spark上下文或类似的东西的通信 . 错误:py4j.java_gateway:发送或接收时出错 . 回溯(最近一次调用最后一次):文件“C:\ Spark \ python \ lib \ py4j-0.10.1-src.zip \ py4j \ java_gateway.py”,第82...