org.apache.reef.tests.evaluator.failure

Class FailureREEF

java.lang.Object

org.apache.reef.tests.evaluator.failure.FailureREEF

public final class FailureREEF
extends Object

Entry point class for REEF failure test.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FailureREEF.Local Command line parameter = true to run locally, or false to run on YARN.
static class	FailureREEF.TimeOut Number of minutes before timeout.

Field Summary

Fields

Modifier and Type	Field and Description
static int	MAX_NUMBER_OF_EVALUATORS The upper limit on the number of Evaluators that the local resourcemanager will hand out concurrently.

Method Summary

Methods

Modifier and Type	Method and Description
static void	main(String[] args)
static LauncherStatus	runFailureReef(Configuration runtimeConfig, int timeout, int numEvaluatorsToSubmit, int numEvaluatorsToFail)

Methods inherited from class java.lang.Object

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

Field Detail

MAX_NUMBER_OF_EVALUATORS

public static final int MAX_NUMBER_OF_EVALUATORS

The upper limit on the number of Evaluators that the local resourcemanager will hand out concurrently.

See Also:

Constant Field Values

Method Detail

runFailureReef

public static LauncherStatus runFailureReef(Configuration runtimeConfig,
                            int timeout,
                            int numEvaluatorsToSubmit,
                            int numEvaluatorsToFail)
                                     throws InjectionException

Throws:

InjectionException

main

public static void main(String[] args)
                 throws InjectionException

Throws:

InjectionException