4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 1229 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
1 s
Locality Level Summary:
Node local: 10
Shuffle Read Size / Records:
9.1 KiB / 195
Shuffle Write Size / Records:
30.7 KiB / 195
Associated Job Ids:
582
DAG Visualization
digraph G { id="graph_1229"; subgraph graph_stage_1229 { id="graph_stage_1229"; isCluster="true"; label="Stage 1229"; subgraph cluster_10132 { id="cluster_10132"; isCluster="true"; label="Exchange"; 3123 [id="node_3123" labelType="html" label="ShuffledRowRDD [3123] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_10215 { id="cluster_10215"; isCluster="true"; label="WholeStageCodegen (375)"; 3139 [id="node_3139" labelType="html" label="MapPartitionsRDD [3139] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_10214 { id="cluster_10214"; isCluster="true"; label="Project"; 3140 [id="node_3140" labelType="html" label="MapPartitionsRDD [3140] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_10176 { id="cluster_10176"; isCluster="true"; label="WholeStageCodegen (376)"; 3141 [id="node_3141" labelType="html" label="MapPartitionsRDD [3141] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_10175 { id="cluster_10175"; isCluster="true"; label="ObjectHashAggregate"; 3142 [id="node_3142" labelType="html" label="MapPartitionsRDD [3142] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_10174 { id="cluster_10174"; isCluster="true"; label="ObjectHashAggregate"; 3143 [id="node_3143" labelType="html" label="MapPartitionsRDD [3143] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_10086 { id="cluster_10086"; isCluster="true"; label="WholeStageCodegen (377)"; 3144 [id="node_3144" labelType="html" label="MapPartitionsRDD [3144] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_10085 { id="cluster_10085"; isCluster="true"; label="Exchange"; 3145 [id="node_3145" labelType="html" label="MapPartitionsRDD [3145] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 3123->3139; 3139->3140; 3140->3141; 3141->3142; 3142->3143; 3143->3144; 3144->3145; }
2850,3123
Event Timeline
Enable zooming
Tasks: 10. 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