4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 99292 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
4 s
Locality Level Summary:
Node local: 37
Shuffle Read Size / Records:
1773.9 KiB / 3960
Shuffle Write Size / Records:
1495.7 KiB / 1956
Associated Job Ids:
5222
DAG Visualization
digraph G { id="graph_99292"; subgraph graph_stage_99292 { id="graph_stage_99292"; isCluster="true"; label="Stage 99292"; subgraph cluster_118740 { id="cluster_118740"; isCluster="true"; label="Exchange"; 45641 [id="node_45641" labelType="html" label="ShuffledRowRDD [45641] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_118737 { id="cluster_118737"; isCluster="true"; label="WholeStageCodegen (4)"; 45642 [id="node_45642" labelType="html" label="MapPartitionsRDD [45642] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_118760 { id="cluster_118760"; isCluster="true"; label="Exchange"; 45652 [id="node_45652" labelType="html" label="ShuffledRowRDD [45652] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_118757 { id="cluster_118757"; isCluster="true"; label="WholeStageCodegen (8)"; 45653 [id="node_45653" labelType="html" label="MapPartitionsRDD [45653] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_118733 { id="cluster_118733"; isCluster="true"; label="WholeStageCodegen (9)"; 45654 [id="node_45654" labelType="html" label="ZippedPartitionsRDD2 [45654] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; 45655 [id="node_45655" labelType="html" label="MapPartitionsRDD [45655] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_118732 { id="cluster_118732"; isCluster="true"; label="ObjectHashAggregate"; 45656 [id="node_45656" labelType="html" label="MapPartitionsRDD [45656] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_118731 { id="cluster_118731"; isCluster="true"; label="Exchange"; 45657 [id="node_45657" labelType="html" label="MapPartitionsRDD [45657] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } } 45641->45642; 45652->45653; 45642->45654; 45653->45654; 45654->45655; 45655->45656; 45656->45657; }
45640,45641
45651,45652
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