本地提交的Spark任务没有返回任何结果。
创始人
2024-11-30 03:00:32
0次

可能原因是本地执行的任务还未完成，需要加上SparkContext的awaitTermination()方法等待任务执行完毕，例如：

from pyspark import SparkContext

sc = SparkContext(appName="example")
data = sc.parallelize([1, 2, 3, 4, 5])
result = data.map(lambda x: x*2).collect()

# 添加等待任务完成的方法
sc.awaitTermination()

print(result)

我们可以使用awaitTermination()方法等待任务完成后再输出结果。

上一篇：本地提交的更改在主存储库中未找到并且已批准的分支“未找到。

下一篇：本地Tomcat服务器配备https CorsHandler返回安全的JSESSIONID cookie，但阻止不安全的JTENANTSESSIONID_dev cookie。

相关内容

热门资讯

9分钟辅助！佛手在线大菠萝技巧... 9分钟辅助！佛手在线大菠萝技巧，hhpoker透视脚本视频，教程书教程（真的有挂）小薇（辅助器软件下...
第7分钟辅助！约局吧开挂，ha... 第7分钟辅助！约局吧开挂，hardrock透视工具，指南书教程（有挂详情）1、hardrock透视工...
第八分钟辅助！德扑圈有透视吗，... 第八分钟辅助！德扑圈有透视吗，hhpoker智能辅助插件，法门教程（有挂解密）1、完成hhpoker...
4分钟辅助！wepoker如何... 4分钟辅助！wepoker如何设置透视，wpk德州局透视，讲义教程（的确有挂）1、点击下载安装，we...
十分钟辅助！佛手在线有挂吗，w... 十分钟辅助！佛手在线有挂吗，wepoker辅助器如何使用，大纲教程（真的有挂）1、wepoker辅助...
2分钟辅助！wepoker怎么... 2分钟辅助！wepoker怎么开辅助，wepoker免费钻石，课程教程（有挂工具）；1、打开软件启动...
六分钟辅助！wepoker安装... 六分钟辅助！wepoker安装教程，wepoker挂，大纲教程（揭秘有挂）1、下载好wepoker安...
三分钟辅助！wepoker透视... 三分钟辅助！wepoker透视脚本免费使用视频，hh poker辅助有用吗，讲义教程（揭秘有挂）1、...
1分钟辅助！hhpoker软件... 1分钟辅助！hhpoker软件可以玩吗，hhpoker辅助软件下载，窍要教程（有挂神器）1、全新机制...
六分钟辅助！pokerworl... 六分钟辅助！pokerworld辅助器，hardrock作弊，法子教程（有挂教程）1、pokerwo...