Package | Description |
---|---|
org.apache.flink.runtime.resourcemanager | |
org.apache.flink.runtime.taskexecutor | |
org.apache.flink.runtime.webmonitor.threadinfo |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<TaskExecutorThreadInfoGateway> |
ResourceManager.requestTaskExecutorThreadInfoGateway(ResourceID taskManagerId,
Time timeout) |
CompletableFuture<TaskExecutorThreadInfoGateway> |
ResourceManagerGateway.requestTaskExecutorThreadInfoGateway(ResourceID taskManagerId,
Time timeout)
Requests the
TaskExecutorGateway . |
Modifier and Type | Interface and Description |
---|---|
interface |
TaskExecutorGateway
TaskExecutor RPC gateway interface. |
Modifier and Type | Class and Description |
---|---|
class |
TaskExecutor
TaskExecutor implementation.
|
class |
TaskExecutorGatewayDecoratorBase
A class that decorates/forwards calls to a
TaskExecutorGateway . |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<JobVertexThreadInfoStats> |
ThreadInfoRequestCoordinator.triggerThreadInfoRequest(Map<org.apache.flink.shaded.guava30.com.google.common.collect.ImmutableSet<ExecutionAttemptID>,CompletableFuture<TaskExecutorThreadInfoGateway>> executionsWithGateways,
int numSamples,
java.time.Duration delayBetweenSamples,
int maxStackTraceDepth)
Triggers collection of thread info stats of a job vertex by combining thread info responses
from given subtasks.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.