4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 99810 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
11 s
Locality Level Summary:
Node local: 20; Process local: 17
Shuffle Read Size / Records:
307.7 KiB / 69
Associated Job Ids:
5265
DAG Visualization
digraph G { id="graph_99810"; subgraph graph_stage_99810 { id="graph_stage_99810"; isCluster="true"; label="Stage 99810"; 46219 [id="node_46219" labelType="html" label="SQLExecutionRDD [46219] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_119962 { id="cluster_119962"; isCluster="true"; label="Exchange"; 46214 [id="node_46214" labelType="html" label="ShuffledRowRDD [46214] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119961 { id="cluster_119961"; isCluster="true"; label="ObjectHashAggregate"; 46215 [id="node_46215" labelType="html" label="MapPartitionsRDD [46215] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119811 { id="cluster_119811"; isCluster="true"; label="WholeStageCodegen (17)"; 46216 [id="node_46216" labelType="html" label="MapPartitionsRDD [46216] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119810 { id="cluster_119810"; isCluster="true"; label="DeserializeToObject"; 46217 [id="node_46217" labelType="html" label="MapPartitionsRDD [46217] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_119805 { id="cluster_119805"; isCluster="true"; label="MapPartitions"; 46218 [id="node_46218" labelType="html" label="MapPartitionsRDD [46218] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120048 { id="cluster_120048"; isCluster="true"; label="mapPartitions"; 46220 [id="node_46220" labelType="html" label="MapPartitionsRDD [46220] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 46214->46215; 46215->46216; 46216->46217; 46217->46218; 46218->46219; 46219->46220; }
46213,46214
46220
46219
46214
46215
46216
46217
46218
46220
Event Timeline
Enable zooming
Tasks: 37. 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