org.apache.flink.runtime.jobmaster

Interface ExecutionDeploymentReconciler

All Known Implementing Classes:

DefaultExecutionDeploymentReconciler

public interface ExecutionDeploymentReconciler

Component for reconciling the deployment state of executions.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	ExecutionDeploymentReconciler.Factory Factory for ExecutionDeploymentReconciler.

Method Summary

Modifier and Type	Method and Description
void	reconcileExecutionDeployments(ResourceID taskExecutorHost, ExecutionDeploymentReport executionDeploymentReport, Map<ExecutionAttemptID,ExecutionDeploymentState> expectedDeployedExecutionIds) Reconciles the deployment states between all reported/expected executions for the given task executor.

Method Detail

reconcileExecutionDeployments

void reconcileExecutionDeployments(ResourceID taskExecutorHost,
                                   ExecutionDeploymentReport executionDeploymentReport,
                                   Map<ExecutionAttemptID,ExecutionDeploymentState> expectedDeployedExecutionIds)

Reconciles the deployment states between all reported/expected executions for the given task executor.

Parameters:

taskExecutorHost - hosting task executor

executionDeploymentReport - task executor report for deployed executions

expectedDeployedExecutionIds - map of expected executions and their current deployment status