4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 101348 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.5 s
Locality Level Summary:
Node local: 1
Shuffle Read Size / Records:
14.7 KiB / 139
Shuffle Write Size / Records:
8.9 KiB / 89
Associated Job Ids:
5594
DAG Visualization
digraph G { id="graph_101348"; subgraph graph_stage_101348 { id="graph_stage_101348"; isCluster="true"; label="Stage 101348"; subgraph cluster_125915 { id="cluster_125915"; isCluster="true"; label="AQEShuffleRead"; 48158 [id="node_48158" labelType="html" label="ShuffledRowRDD [48158] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_125903 { id="cluster_125903"; isCluster="true"; label="WholeStageCodegen (49)"; 48159 [id="node_48159" labelType="html" label="MapPartitionsRDD [48159] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_125902 { id="cluster_125902"; isCluster="true"; label="Generate"; 48160 [id="node_48160" labelType="html" label="MapPartitionsRDD [48160] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_125901 { id="cluster_125901"; isCluster="true"; label="ObjectHashAggregate"; 48161 [id="node_48161" labelType="html" label="MapPartitionsRDD [48161] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_125900 { id="cluster_125900"; isCluster="true"; label="ObjectHashAggregate"; 48162 [id="node_48162" labelType="html" label="MapPartitionsRDD [48162] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_125886 { id="cluster_125886"; isCluster="true"; label="WholeStageCodegen (50)"; 48163 [id="node_48163" labelType="html" label="MapPartitionsRDD [48163] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_125885 { id="cluster_125885"; isCluster="true"; label="Exchange"; 48164 [id="node_48164" labelType="html" label="MapPartitionsRDD [48164] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 48158->48159; 48159->48160; 48160->48161; 48161->48162; 48162->48163; 48163->48164; }
48157,48158
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