org.apache.flink.runtime.taskexecutor

Interface TaskExecutorGateway

All Superinterfaces:

RpcGateway

All Known Implementing Classes:

TaskExecutor

public interface TaskExecutorGateway
extends RpcGateway

TaskExecutor RPC gateway interface

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Acknowledge>	cancelTask(ExecutionAttemptID executionAttemptID, Time timeout) Cancel the given task.
CompletableFuture<Acknowledge>	confirmCheckpoint(ExecutionAttemptID executionAttemptID, long checkpointId, long checkpointTimestamp) Confirm a checkpoint for the given task.
void	disconnectJobManager(JobID jobId, Exception cause) Disconnects the given JobManager from the TaskManager.
void	disconnectResourceManager(Exception cause) Disconnects the ResourceManager from the TaskManager.
void	failPartition(ExecutionAttemptID executionAttemptID) Fail all intermediate result partitions of the given task.
void	heartbeatFromJobManager(ResourceID heartbeatOrigin) Heartbeat request from the job manager
void	heartbeatFromResourceManager(ResourceID heartbeatOrigin) Heartbeat request from the resource manager
CompletableFuture<Acknowledge>	requestSlot(SlotID slotId, JobID jobId, AllocationID allocationId, String targetAddress, ResourceManagerId resourceManagerId, Time timeout) Requests a slot from the TaskManager
CompletableFuture<Acknowledge>	stopTask(ExecutionAttemptID executionAttemptID, Time timeout) Stop the given task.
CompletableFuture<Acknowledge>	submitTask(TaskDeploymentDescriptor tdd, JobMasterId jobMasterId, Time timeout) Submit a Task to the TaskExecutor.
CompletableFuture<Acknowledge>	triggerCheckpoint(ExecutionAttemptID executionAttemptID, long checkpointID, long checkpointTimestamp, CheckpointOptions checkpointOptions) Trigger the checkpoint for the given task.
CompletableFuture<Acknowledge>	updatePartitions(ExecutionAttemptID executionAttemptID, Iterable<PartitionInfo> partitionInfos, Time timeout) Update the task where the given partitions can be found.

Methods inherited from interface org.apache.flink.runtime.rpc.RpcGateway

getAddress, getHostname

Method Detail

requestSlot

CompletableFuture<Acknowledge> requestSlot(SlotID slotId,
                                           JobID jobId,
                                           AllocationID allocationId,
                                           String targetAddress,
                                           ResourceManagerId resourceManagerId,
                                           Time timeout)

Requests a slot from the TaskManager

Parameters:

slotId - slot id for the request

jobId - for which to request a slot

allocationId - id for the request

targetAddress - to which to offer the requested slots

resourceManagerId - current leader id of the ResourceManager

timeout - for the operation

Returns:

answer to the slot request

submitTask

CompletableFuture<Acknowledge> submitTask(TaskDeploymentDescriptor tdd,
                                          JobMasterId jobMasterId,
                                          Time timeout)

Submit a Task to the TaskExecutor.

Parameters:

tdd - describing the task to submit

jobMasterId - identifying the submitting JobMaster

timeout - of the submit operation

Returns:

Future acknowledge of the successful operation

updatePartitions

CompletableFuture<Acknowledge> updatePartitions(ExecutionAttemptID executionAttemptID,
                                                Iterable<PartitionInfo> partitionInfos,
                                                Time timeout)

Update the task where the given partitions can be found.

Parameters:

executionAttemptID - identifying the task

partitionInfos - telling where the partition can be retrieved from

timeout - for the update partitions operation

Returns:

Future acknowledge if the partitions have been successfully updated

failPartition

void failPartition(ExecutionAttemptID executionAttemptID)

Fail all intermediate result partitions of the given task.

Parameters:

executionAttemptID - identifying the task

triggerCheckpoint

CompletableFuture<Acknowledge> triggerCheckpoint(ExecutionAttemptID executionAttemptID,
                                                 long checkpointID,
                                                 long checkpointTimestamp,
                                                 CheckpointOptions checkpointOptions)

Trigger the checkpoint for the given task. The checkpoint is identified by the checkpoint ID and the checkpoint timestamp.

Parameters:

executionAttemptID - identifying the task

checkpointID - unique id for the checkpoint

checkpointTimestamp - is the timestamp when the checkpoint has been initiated

checkpointOptions - for performing the checkpoint

Returns:

Future acknowledge if the checkpoint has been successfully triggered

confirmCheckpoint

CompletableFuture<Acknowledge> confirmCheckpoint(ExecutionAttemptID executionAttemptID,
                                                 long checkpointId,
                                                 long checkpointTimestamp)

Confirm a checkpoint for the given task. The checkpoint is identified by the checkpoint ID and the checkpoint timestamp.

Parameters:

executionAttemptID - identifying the task

checkpointId - unique id for the checkpoint

checkpointTimestamp - is the timestamp when the checkpoint has been initiated

Returns:

Future acknowledge if the checkpoint has been successfully confirmed

stopTask

CompletableFuture<Acknowledge> stopTask(ExecutionAttemptID executionAttemptID,
                                        Time timeout)

Stop the given task.

Parameters:

executionAttemptID - identifying the task

timeout - for the stop operation

Returns:

Future acknowledge if the task is successfully stopped

cancelTask

CompletableFuture<Acknowledge> cancelTask(ExecutionAttemptID executionAttemptID,
                                          Time timeout)

Cancel the given task.

Parameters:

executionAttemptID - identifying the task

timeout - for the cancel operation

Returns:

Future acknowledge if the task is successfully canceled

heartbeatFromJobManager

void heartbeatFromJobManager(ResourceID heartbeatOrigin)

Heartbeat request from the job manager

Parameters:

heartbeatOrigin - unique id of the job manager

heartbeatFromResourceManager

void heartbeatFromResourceManager(ResourceID heartbeatOrigin)

Heartbeat request from the resource manager

Parameters:

heartbeatOrigin - unique id of the resource manager

disconnectJobManager

void disconnectJobManager(JobID jobId,
                          Exception cause)

Disconnects the given JobManager from the TaskManager.

Parameters:

jobId - JobID for which the JobManager was the leader

cause - for the disconnection from the JobManager

disconnectResourceManager

void disconnectResourceManager(Exception cause)

Disconnects the ResourceManager from the TaskManager.

Parameters:

cause - for the disconnection from the ResourceManager