Automatic end-to-end test for local recovery (including sticky allocation).
List of possible input parameters for this job:
- checkpointDir: the checkpoint directory, required.
- parallelism: the parallelism of the job, default 1.
- maxParallelism: the maximum parallelism of the job, default 1.
- checkpointInterval: the checkpointing interval in milliseconds, default 1000.
- restartDelay: the delay of the fixed delay restart strategy, default 0.
- externalizedCheckpoints: flag to activate externalized checkpoints, default
false
.
- stateBackend: choice for state backend between
file
and rocks
, default file
.
- killJvmOnFail: flag that determines whether or not an artificial failure induced by the test kills the JVM or not.
- asyncCheckpoints: flag for async checkpoints with file state backend, default
true
.
- incrementalCheckpoints: flag for incremental checkpoint with rocks state backend, default
false
.
- delay: sleep delay to throttle down the production of the source, default 0.
- maxAttempts: the maximum number of run attempts, before the job finishes with success, default 3.
- valueSize: size of the artificial value for each key in bytes, default 10.