public class FaultToleranceContext extends Context
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
FAILURE_TIMEOUT |
static int |
FAILURE_TIMEOUT_DEFAULT |
static java.lang.String |
MAX_MPIJOB_RESTARTS |
static int |
MAX_MPIJOB_RESTARTS_DEFAULT |
static java.lang.String |
MAX_REEXECUTES |
static int |
MAX_REEXECUTES_DEFAULT |
static java.lang.String |
MAX_WORKER_RESTARTS |
static int |
MAX_WORKER_RESTARTS_DEFAULT |
AURORA_SCRIPT, CHECKPOINT_YAML, CLUSTER, CLUSTER_CONF, CLUSTER_HOME, CORE_YAML, DATA_YAML, defaults, GRAPH_TYPE, HOME, JAVA_HOME, JOB, JOB_ARCHIVE_DIRECTORY, JOB_ID, JOB_NAME, JOB_OBJECT, NETWORK_YAML, OPERATION_NAME, OVERRIDE_YAML, RESOURCE_SCHEDULER_YAML, STREAMING, substitutions, TASK_YAML, TWISTER2_BANDWIDTH, TWISTER2_BIN, TWISTER2_CLUSTER_TYPE, TWISTER2_COMMON_CONF_DIR, TWISTER2_CONF, TWISTER2_CONTAINER_ID, TWISTER2_DIRECT_EDGE, TWISTER2_DIST, TWISTER2_GRAPH_JOB, TWISTER2_HOME, TWISTER2_LATENCY, TWISTER2_LIB, TWISTER2_MAX_TASK_INSTANCES_PER_WORKER, TWISTER2_TASK_INSTANCE_ODD_PARALLELISM, TWISTER2_TSET_JOB, TWISTER2_WORKER_INSTANCES, TWISTER2_WORKER_INSTANCES_DEFAULT, USER_NAME, VERBOSE
Constructor and Description |
---|
FaultToleranceContext() |
Modifier and Type | Method and Description |
---|---|
static int |
maxMpiJobRestarts(Config cfg) |
static int |
maxReExecutes(Config cfg) |
static int |
maxWorkerRestarts(Config cfg) |
static int |
sessionTimeout(Config cfg) |
auroraScript, checkpointCofigurationFile, checkpointConfigurationFile, clusterType, commonConfDir, conf, containerId, dataConfigurationFile, distDirectory, getDefaults, getDoublePropertyValue, getIntPropertyValue, getLongPropertyValue, getStringPropertyValue, isKubernetesCluster, jobId, jobName, libDirectory, networkConfigurationFile, resourceSchedulerConfigurationFile, systemConfigurationFile, taskConfigurationFile, twister2Home, userName, verbose, workerInstances
public static final java.lang.String FAILURE_TIMEOUT
public static final int FAILURE_TIMEOUT_DEFAULT
public static final java.lang.String MAX_REEXECUTES
public static final int MAX_REEXECUTES_DEFAULT
public static final java.lang.String MAX_WORKER_RESTARTS
public static final int MAX_WORKER_RESTARTS_DEFAULT
public static final java.lang.String MAX_MPIJOB_RESTARTS
public static final int MAX_MPIJOB_RESTARTS_DEFAULT