【Spark】RDD的序列化问题_rdd foreach 写文件序列化问题-CSDN博客

网站介绍:文章浏览阅读2k次。发现问题object serialDemo { def main(args: Array[String]): Unit = { val sparConf = new SparkConf().setMaster("local").setAppName("WordCount") val sc = new SparkContext(sparConf) val rdd: RDD[String] = sc.makeRDD(Array("hello world", "hello sp_rdd foreach 写文件序列化问题