org.apache.giraph

Class TestAutoCheckpoint

java.lang.Object

org.apache.giraph.BspCase

org.apache.giraph.TestAutoCheckpoint

All Implemented Interfaces:

org.apache.zookeeper.Watcher

public class TestAutoCheckpoint
extends BspCase

Unit test for automated checkpoint restarting

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.zookeeper.Watcher

org.apache.zookeeper.Watcher.Event

Field Summary

Fields inherited from class org.apache.giraph.BspCase

READER_VERTICES_OPT

Constructor Summary

Constructors

Constructor and Description
TestAutoCheckpoint()

Method Summary

Modifier and Type	Method and Description
void	testSingleFault() Run a job that requires checkpointing and will have a worker crash and still recover from a previous checkpoint.

Methods inherited from class org.apache.giraph.BspCase

getCallingMethodName, getNumResults, getNumWorkers, getSinglePartFileStatus, getTempPath, getZooKeeperList, prepareJob, prepareJob, process, removeAndSetOutput, runningInDistributedMode, setUp, setupConfiguration, tearDown

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TestAutoCheckpoint

public TestAutoCheckpoint()

Method Detail

testSingleFault

public void testSingleFault()
                     throws IOException,
                            InterruptedException,
                            ClassNotFoundException

Run a job that requires checkpointing and will have a worker crash and still recover from a previous checkpoint.

Throws:

IOException

ClassNotFoundException

InterruptedException