最近在看SPARK，跟着慕课网上的视频操作，感觉跟老师讲的一模一样，但就是打印不出结果。
val rdd=sc.parallelize(Array(1,2,3,3))
rdd.foreach(println)
打印后无任何显示，很奇怪。
后来查了下，是因为数据分发到不同节点上，打印在各节点的显示上，
解决方法有两种：
一。
rdd.collect.foreach(println)
结果：
1
2
3
3
这里的collect()方法的作用是收集分布在各个worker的数据到driver节点。
二。
rdd.take(3).foreach(println)
结果：
1
2
3
参考：
https://blog.csdn.net/qq_34872215/article/details/107638622
最近在看SPARK，跟着慕课网上的视频操作，感觉跟老师讲的一模一样，但就是打印不出结果。 打印后无任何显示，很奇怪...
备注：Flink 1.9.0 一.Sink概述 Flink没有类似于spark中foreach方法，让用户进行迭代...
在 Spark 性能调优中，经常会被建议尽量用 mappartition 操作去替代 map 操作。本文将会对这...
问题 JS中foreach语义中希望使用break打断循环失败。 JS中Foreach为什么不能break？如何实...
流处理基本步骤： sink Flink没有类似于spark中foreach方法，让用户进行迭代的操作。虽有对外的输...
Java中print、printf、println的区别？ print将它的参数显示在命令窗口，并将输出光标定位在...
问题 1.foreach操作 NSGenericException这个异常最容易出现在foreach操作中，在fo...
一、Actions算子-- 12种 启动spark: 1. foreach 打印输出 2. saveAsTextF...
在一个2015年的spark调查中显示，91%的spark用户是因为spark的高性能才选择使用它的。所以spar...
在项目中使用forEach进行遍历，是无法实现：达到某一条件，希望跳出循环，代码不继续执行。 例： 原因：forE...
本文标题：spark中foreach(println)无显示问题
本文链接：https://www.haomeiwen.com/subject/nhfcsltx.html
网友评论