4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 1228 (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:
18.9 KiB / 195
Associated Job Ids:
581
DAG Visualization
digraph G { id="graph_1228"; subgraph graph_stage_1228 { id="graph_stage_1228"; isCluster="true"; label="Stage 1228"; 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_10188 { id="cluster_10188"; isCluster="true"; label="WholeStageCodegen (378)"; 3132 [id="node_3132" labelType="html" label="MapPartitionsRDD [3132] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_10187 { id="cluster_10187"; isCluster="true"; label="Project"; 3133 [id="node_3133" labelType="html" label="MapPartitionsRDD [3133] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_10145 { id="cluster_10145"; isCluster="true"; label="WholeStageCodegen (379)"; 3134 [id="node_3134" labelType="html" label="MapPartitionsRDD [3134] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_10144 { id="cluster_10144"; isCluster="true"; label="ObjectHashAggregate"; 3135 [id="node_3135" labelType="html" label="MapPartitionsRDD [3135] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_10143 { id="cluster_10143"; isCluster="true"; label="ObjectHashAggregate"; 3136 [id="node_3136" labelType="html" label="MapPartitionsRDD [3136] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_10093 { id="cluster_10093"; isCluster="true"; label="WholeStageCodegen (380)"; 3137 [id="node_3137" labelType="html" label="MapPartitionsRDD [3137] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_10092 { id="cluster_10092"; isCluster="true"; label="Exchange"; 3138 [id="node_3138" labelType="html" label="MapPartitionsRDD [3138] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 3123->3132; 3132->3133; 3133->3134; 3134->3135; 3135->3136; 3136->3137; 3137->3138; }
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