Hi, @andrewor14, doCheckpoint is originally called in SparkContext.runJob, however according to the comments of this function, it is called by DAGScheduler, nothing about functionality, just found this inconsistency and fix it