Page History

public interface TaskExecutorGateway extends RpcGateway, TaskExecutorOperatorEventGateway {
    /**
     * Request a thread info sample from the given task.
     *
     * @param taskExecutionAttemptId identifying the task to sample
     * @param requestId of the sample
     * @param numSubSamples to take from the given task
     * @param delayBetweenSamples to wait for
     * @param maxStackTraceDepthrequestParams parameters of the returned samplerequest
     * @param timeout of the request
     * @return Future of stack trace sample response
     */
    CompletableFuture<TaskThreadInfoResponse> requestThreadInfoSamples(
            ExecutionAttemptID taskExecutionAttemptId,
            int requestId,
            int numSubSamples,
            Time delayBetweenSamples,
            int maxStackTraceDepthThreadInfoSamplesRequest requestParams,
            Time timeout);
}