4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 101349 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.4 s
Locality Level Summary:
Node local: 1
Shuffle Read Size / Records:
14.7 KiB / 139
Shuffle Write Size / Records:
8.4 KiB / 89
Associated Job Ids:
5595
DAG Visualization
digraph G { id="graph_101349"; subgraph graph_stage_101349 { id="graph_stage_101349"; isCluster="true"; label="Stage 101349"; subgraph cluster_125933 { id="cluster_125933"; isCluster="true"; label="AQEShuffleRead"; 48165 [id="node_48165" labelType="html" label="ShuffledRowRDD [48165] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_125919 { id="cluster_125919"; isCluster="true"; label="WholeStageCodegen (51)"; 48166 [id="node_48166" labelType="html" label="MapPartitionsRDD [48166] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_125918 { id="cluster_125918"; isCluster="true"; label="Generate"; 48167 [id="node_48167" labelType="html" label="MapPartitionsRDD [48167] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_125917 { id="cluster_125917"; isCluster="true"; label="ObjectHashAggregate"; 48168 [id="node_48168" labelType="html" label="MapPartitionsRDD [48168] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_125916 { id="cluster_125916"; isCluster="true"; label="ObjectHashAggregate"; 48169 [id="node_48169" labelType="html" label="MapPartitionsRDD [48169] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_125894 { id="cluster_125894"; isCluster="true"; label="WholeStageCodegen (52)"; 48170 [id="node_48170" labelType="html" label="MapPartitionsRDD [48170] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_125893 { id="cluster_125893"; isCluster="true"; label="Exchange"; 48171 [id="node_48171" labelType="html" label="MapPartitionsRDD [48171] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 48165->48166; 48166->48167; 48167->48168; 48168->48169; 48169->48170; 48170->48171; }
48157,48165
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