Package | Description |
---|---|
org.apache.flink.runtime.rest.handler.job | |
org.apache.flink.runtime.webmonitor.threadinfo |
Constructor and Description |
---|
JobVertexFlameGraphHandler(GatewayRetriever<? extends RestfulGateway> leaderRetriever,
Time timeout,
Map<String,String> responseHeaders,
ExecutionGraphCache executionGraphCache,
Executor executor,
JobVertexThreadInfoTracker<JobVertexThreadInfoStats> threadInfoOperatorTracker) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<JobVertexThreadInfoStats> |
ThreadInfoRequestCoordinator.triggerThreadInfoRequest(Map<ExecutionAttemptID,CompletableFuture<TaskExecutorThreadInfoGateway>> executionWithGateways,
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.
|
Modifier and Type | Method and Description |
---|---|
static JobVertexFlameGraph |
JobVertexFlameGraphFactory.createFullFlameGraphFrom(JobVertexThreadInfoStats sample)
Converts
JobVertexThreadInfoStats into a FlameGraph. |
static JobVertexFlameGraph |
JobVertexFlameGraphFactory.createOffCpuFlameGraph(JobVertexThreadInfoStats sample)
Converts
JobVertexThreadInfoStats into a FlameGraph representing blocked (Off-CPU)
threads. |
static JobVertexFlameGraph |
JobVertexFlameGraphFactory.createOnCpuFlameGraph(JobVertexThreadInfoStats sample)
Converts
JobVertexThreadInfoStats into a FlameGraph representing actively running
(On-CPU) threads. |
Modifier and Type | Method and Description |
---|---|
static <T extends Statistics> |
JobVertexThreadInfoTrackerBuilder.newBuilder(GatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever,
java.util.function.Function<JobVertexThreadInfoStats,T> createStatsFn,
ScheduledExecutorService executor,
Time restTimeout)
Create a new
JobVertexThreadInfoTrackerBuilder . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.