Added support for rescheduling unprocessed batches on master failure.
Fixed checkpoint testcases