public class DefaultCheckpointPlanCalculator extends Object implements CheckpointPlanCalculator
CheckpointPlanCalculator. If all tasks are running, it directly marks all the sources as tasks to trigger, otherwise it would try to find the running tasks without running processors as tasks to trigger.
|Constructor and Description|
|Modifier and Type||Method and Description|
Calculates the plan of the next checkpoint.
public DefaultCheckpointPlanCalculator(JobID jobId, CheckpointPlanCalculatorContext context, Iterable<ExecutionJobVertex> jobVerticesInTopologyOrderIterable, boolean allowCheckpointsAfterTasksFinished)
public CompletableFuture<CheckpointPlan> calculateCheckpointPlan()
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.