4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 92362 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
4 s
Locality Level Summary:
Node local: 19; Process local: 18
Shuffle Read Size / Records:
119.7 KiB / 82
Shuffle Write Size / Records:
112.9 KiB / 28
Associated Job Ids:
4906
DAG Visualization
digraph G { id="graph_92362"; subgraph graph_stage_92362 { id="graph_stage_92362"; isCluster="true"; label="Stage 92362"; subgraph cluster_111244 { id="cluster_111244"; isCluster="true"; label="Exchange"; 42652 [id="node_42652" labelType="html" label="ShuffledRowRDD [42652] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111241 { id="cluster_111241"; isCluster="true"; label="WholeStageCodegen (4)"; 42653 [id="node_42653" labelType="html" label="MapPartitionsRDD [42653] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111264 { id="cluster_111264"; isCluster="true"; label="Exchange"; 42663 [id="node_42663" labelType="html" label="ShuffledRowRDD [42663] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111261 { id="cluster_111261"; isCluster="true"; label="WholeStageCodegen (8)"; 42664 [id="node_42664" labelType="html" label="MapPartitionsRDD [42664] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111237 { id="cluster_111237"; isCluster="true"; label="WholeStageCodegen (9)"; 42665 [id="node_42665" labelType="html" label="ZippedPartitionsRDD2 [42665] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; 42666 [id="node_42666" labelType="html" label="MapPartitionsRDD [42666] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111236 { id="cluster_111236"; isCluster="true"; label="ObjectHashAggregate"; 42667 [id="node_42667" labelType="html" label="MapPartitionsRDD [42667] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_111235 { id="cluster_111235"; isCluster="true"; label="Exchange"; 42668 [id="node_42668" labelType="html" label="MapPartitionsRDD [42668] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } } 42652->42653; 42663->42664; 42653->42665; 42664->42665; 42665->42666; 42666->42667; 42667->42668; }
42651,42652
42662,42663
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