Package org.apache.flink.runtime.taskexecutor

Interface TaskExecutorThreadInfoGateway

All Known Subinterfaces:

TaskExecutorGateway

All Known Implementing Classes:

TaskExecutor, TaskExecutorGatewayDecoratorBase

public interface TaskExecutorThreadInfoGateway

RPC gateway for requesting ThreadInfoSample.

Method Summary

Modifier and Type	Method	Description
CompletableFuture<TaskThreadInfoResponse>	requestThreadInfoSamples(Collection<ExecutionAttemptID> taskExecutionAttemptIds, ThreadInfoSamplesRequest requestParams, Duration timeout)	Request a thread info sample from the given tasks.

Method Detail

requestThreadInfoSamples

CompletableFuture<TaskThreadInfoResponse> requestThreadInfoSamples(Collection<ExecutionAttemptID> taskExecutionAttemptIds,
                                                                   ThreadInfoSamplesRequest requestParams,
                                                                   Duration timeout)

Request a thread info sample from the given tasks.

Parameters:

taskExecutionAttemptIds - identifying the task to sample

requestParams - parameters of the request

timeout - of the request

Returns:

Future of stack trace sample response