SPARK-11267: the race condition of two checkpoints in a batch | 1.6 sec | Passed |
SPARK-28912: Fix MatchError in getCheckpointFiles | 98 ms | Passed |
SPARK-30199 get ui port and blockmanager port | 1.5 sec | Passed |
SPARK-6847: stack overflow when updateStateByKey is followed by a checkpointed dstream | 1.3 sec | Passed |
[host|port] from checkpoint | 1.2 sec | Passed |
basic rdd checkpoints + dstream graph checkpoint recovery | 11 sec | Passed |
non-existent checkpoint dir | 4 ms | Passed |
recovery from checkpoint contains array object | 2.8 sec | Passed |
recovery maintains rate controller | 4.7 sec | Passed |
recovery of conf through checkpoints | 1.7 sec | Passed |
recovery with file input stream | 9.2 sec | Passed |
recovery with invertible reduceByKeyAndWindow operation | 5.8 sec | Passed |
recovery with map and reduceByKey operations | 2.5 sec | Passed |
recovery with saveAsHadoopFile inside transform operation | 6.6 sec | Passed |
recovery with saveAsHadoopFiles operation | 10 sec | Passed |
recovery with saveAsNewAPIHadoopFiles operation | 7.1 sec | Passed |
recovery with updateStateByKey operation | 7.5 sec | Passed |
restore invoking times | 2.2 sec | Passed |