4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 1237 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.2 s
Locality Level Summary:
Node local: 1
Shuffle Read Size / Records:
19.6 KiB / 195
Associated Job Ids:
585
DAG Visualization
digraph G { id="graph_1237"; subgraph graph_stage_1237 { id="graph_stage_1237"; isCluster="true"; label="Stage 1237"; subgraph cluster_10281 { id="cluster_10281"; isCluster="true"; label="AQEShuffleRead"; 3150 [id="node_3150" labelType="html" label="ShuffledRowRDD [3150] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_10270 { id="cluster_10270"; isCluster="true"; label="WholeStageCodegen (389)"; 3151 [id="node_3151" labelType="html" label="MapPartitionsRDD [3151] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_10269 { id="cluster_10269"; isCluster="true"; label="Project"; 3152 [id="node_3152" labelType="html" label="MapPartitionsRDD [3152] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_10268 { id="cluster_10268"; isCluster="true"; label="ObjectHashAggregate"; 3153 [id="node_3153" labelType="html" label="MapPartitionsRDD [3153] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_10267 { id="cluster_10267"; isCluster="true"; label="Exchange"; 3154 [id="node_3154" labelType="html" label="MapPartitionsRDD [3154] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 3150->3151; 3151->3152; 3152->3153; 3153->3154; }
3122,3150
Event Timeline
Enable zooming
Tasks: 1. 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