org.apache.flink.runtime.jobmaster

Interface ExecutionDeploymentReconciliationHandler

public interface ExecutionDeploymentReconciliationHandler

Interface for triggering actions in case of state mismatches.

Method Summary

Modifier and Type	Method and Description
void	onMissingDeploymentsOf(Collection<ExecutionAttemptID> executionAttemptIds, ResourceID hostingTaskExecutor) Called if some executions are expected to be hosted on a task executor, but aren't.
void	onUnknownDeploymentsOf(Collection<ExecutionAttemptID> executionAttemptIds, ResourceID hostingTaskExecutor) Called if some executions are hosted on a task executor, but we don't expect them.

Method Detail

onMissingDeploymentsOf

void onMissingDeploymentsOf(Collection<ExecutionAttemptID> executionAttemptIds,
                            ResourceID hostingTaskExecutor)

Called if some executions are expected to be hosted on a task executor, but aren't.

Parameters:

executionAttemptIds - ids of the missing deployments

hostingTaskExecutor - expected hosting task executor

onUnknownDeploymentsOf

void onUnknownDeploymentsOf(Collection<ExecutionAttemptID> executionAttemptIds,
                            ResourceID hostingTaskExecutor)

Called if some executions are hosted on a task executor, but we don't expect them.

Parameters:

executionAttemptIds - ids of the unknown executions

hostingTaskExecutor - hosting task executor