4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 107678 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
4 s
Locality Level Summary:
Node local: 7; Process local: 30
Shuffle Read Size / Records:
45.7 KiB / 11
Associated Job Ids:
6006
DAG Visualization
digraph G { id="graph_107678"; subgraph graph_stage_107678 { id="graph_stage_107678"; isCluster="true"; label="Stage 107678"; 52252 [id="node_52252" labelType="html" label="SQLExecutionRDD [52252] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_136154 { id="cluster_136154"; isCluster="true"; label="Exchange"; 52247 [id="node_52247" labelType="html" label="ShuffledRowRDD [52247] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136153 { id="cluster_136153"; isCluster="true"; label="ObjectHashAggregate"; 52248 [id="node_52248" labelType="html" label="MapPartitionsRDD [52248] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136003 { id="cluster_136003"; isCluster="true"; label="WholeStageCodegen (17)"; 52249 [id="node_52249" labelType="html" label="MapPartitionsRDD [52249] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136002 { id="cluster_136002"; isCluster="true"; label="DeserializeToObject"; 52250 [id="node_52250" labelType="html" label="MapPartitionsRDD [52250] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_135997 { id="cluster_135997"; isCluster="true"; label="MapPartitions"; 52251 [id="node_52251" labelType="html" label="MapPartitionsRDD [52251] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_136240 { id="cluster_136240"; isCluster="true"; label="mapPartitions"; 52253 [id="node_52253" labelType="html" label="MapPartitionsRDD [52253] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 52247->52248; 52248->52249; 52249->52250; 52250->52251; 52251->52252; 52252->52253; }
52246,52247
52253
52252
52247
52248
52249
52250
52251
52253
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