org.apache.flink.runtime.executiongraph.failover.flip1

Interface RestartBackoffTimeStrategy

All Known Implementing Classes:

ExponentialDelayRestartBackoffTimeStrategy, FailureRateRestartBackoffTimeStrategy, FixedDelayRestartBackoffTimeStrategy, NoRestartBackoffTimeStrategy

public interface RestartBackoffTimeStrategy

Strategy to decide whether to restart failed tasks and the delay to do the restarting.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	RestartBackoffTimeStrategy.Factory The factory to instantiate RestartBackoffTimeStrategy.

Method Summary

Modifier and Type	Method and Description
boolean	canRestart() Returns whether a restart should be conducted.
long	getBackoffTime() Returns the delay to do the restarting.
void	notifyFailure(Throwable cause) Notify the strategy about the task failure cause.

Method Detail

canRestart

boolean canRestart()

Returns whether a restart should be conducted.

Returns:

whether a restart should be conducted

getBackoffTime

long getBackoffTime()

Returns the delay to do the restarting.

Returns:

the delay to do the restarting

notifyFailure

void notifyFailure(Throwable cause)

Notify the strategy about the task failure cause.

Parameters:

cause - of the task failure