Spark RDD 的检查点--一种容错机制

step1、进入spark-shell   step2、scala> sc.setCheckpointDir("hdfs://bigdata121:9000/sparkckpt1004") 设置完成后会生成,检查点目录 step3、设置RDD的checkpoint scala> rdd.checkpoint <console>:24: error: not found: value rdd    
相关文章
相关标签/搜索