edu.iu.dsc.tws.api.faulttolerance

Interface JobFaultListener

All Known Implementing Classes:

BarrierMonitor, CheckpointManager

public interface JobFaultListener

This interface will be implemented by CheckpointManager It will get events from JobMaster when some faults occur and the job state is restored

Method Summary

Modifier and Type	Method and Description
void	faultOccurred() this is called when a worker failed in the job it is also called when a worker is restarted before its failure message received
void	faultRestored() this is called when all workers restored and they all come to a barrier after the barrier

Method Detail

faultOccurred

void faultOccurred()

this is called when a worker failed in the job it is also called when a worker is restarted before its failure message received

faultRestored

void faultRestored()

this is called when all workers restored and they all come to a barrier after the barrier