文章浏览阅读3k次。[jifeng@feng03 spark-1.4.0-bin-hadoop2.6]$ ./bin/spark-submit --class "SimpleApp" --master spark://feng03:7077 /home/jifeng/code/simple/target/scala-2.10/simple-project_2.10-1.0.jar15/08/20 23:23:52_spark.mapoutputtrackermasterendpoint:asked...
admin
文章浏览阅读2.3k次。1,在SparkEnv.create()初始化了MapOutputTrackerMaster(记录ShuffleMapTask输出信息)val mapOutputTracker = if (isDriver) { /* MapOutputTrackerMaster属于driver,这里使用TimeStampedHashMap来跟踪 map的输出信息,也可以将旧信息进行清除 * ......
admin
友情链接申请要求: 不违法不降权 权重相当 请联系QQ:737597453