對于在調(diào)用rdd.checkpoint()之前就做過action的rdd 足删,checkpoint是無效的赶袄,不會產(chǎn)生checkpoint文件
必須在checkpoint之前緊接再來一個map(空操作也可)
rdd2 = rdd.map {....};
rdd2.count();
rdd2.checkpoint();
rdd2.count() (無效)
rdd2 = rdd.map {....};
rdd2.checkpoint();
rdd2.count() (有效)
rdd2 = rdd.map {....};
rdd2.count();
rdd2 = rdd2.map(a=>a)
rdd2.checkpoint();
rdd2.count() (有效)