4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 105908 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
5 s
Locality Level Summary:
Node local: 24; Process local: 13
Shuffle Read Size / Records:
4.2 KiB / 45
Associated Job Ids:
5913
DAG Visualization
digraph G { id="graph_105908"; subgraph graph_stage_105908 { id="graph_stage_105908"; isCluster="true"; label="Stage 105908"; 51036 [id="node_51036" labelType="html" label="SQLExecutionRDD [51036] [Unordered]<br>save at KafkaAdapter.java:173}"]; subgraph cluster_133410 { id="cluster_133410"; isCluster="true"; label="Exchange"; 51032 [id="node_51032" labelType="html" label="ShuffledRowRDD [51032] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_133398 { id="cluster_133398"; isCluster="true"; label="WholeStageCodegen (8)"; 51033 [id="node_51033" labelType="html" label="MapPartitionsRDD [51033] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_133397 { id="cluster_133397"; isCluster="true"; label="Project"; 51034 [id="node_51034" labelType="html" label="MapPartitionsRDD [51034] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_133379 { id="cluster_133379"; isCluster="true"; label="WholeStageCodegen (9)"; 51035 [id="node_51035" labelType="html" label="MapPartitionsRDD [51035] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 51032->51033; 51033->51034; 51034->51035; 51035->51036; }
51018,51032
Event Timeline
Enable zooming
Tasks: 37. 1 Pages. Jump to
. Show
items in a page.
Go
Scheduler Delay
Task Deserialization Time
Shuffle Read Time
Executor Computing Time
Shuffle Write Time
Result Serialization Time
Getting Result Time