4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 191081 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
8 s
Locality Level Summary:
Node local: 30
Shuffle Read Size / Records:
15.9 MiB / 159872
Shuffle Write Size / Records:
12.7 MiB / 78568
Associated Job Ids:
52762
DAG Visualization
digraph G { id="graph_191081"; subgraph graph_stage_191081 { id="graph_stage_191081"; isCluster="true"; label="Stage 191081"; subgraph cluster_1112645 { id="cluster_1112645"; isCluster="true"; label="Exchange"; 425795 [id="node_425795" labelType="html" label="ShuffledRowRDD [425795] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1112642 { id="cluster_1112642"; isCluster="true"; label="WholeStageCodegen (9)"; 425796 [id="node_425796" labelType="html" label="MapPartitionsRDD [425796] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1112694 { id="cluster_1112694"; isCluster="true"; label="Exchange"; 425822 [id="node_425822" labelType="html" label="ShuffledRowRDD [425822] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1112691 { id="cluster_1112691"; isCluster="true"; label="WholeStageCodegen (17)"; 425823 [id="node_425823" labelType="html" label="MapPartitionsRDD [425823] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1112638 { id="cluster_1112638"; isCluster="true"; label="WholeStageCodegen (18)"; 425824 [id="node_425824" labelType="html" label="ZippedPartitionsRDD2 [425824] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 425825 [id="node_425825" labelType="html" label="MapPartitionsRDD [425825] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1112637 { id="cluster_1112637"; isCluster="true"; label="ObjectHashAggregate"; 425826 [id="node_425826" labelType="html" label="MapPartitionsRDD [425826] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1112636 { id="cluster_1112636"; isCluster="true"; label="Exchange"; 425827 [id="node_425827" labelType="html" label="MapPartitionsRDD [425827] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 425795->425796; 425822->425823; 425796->425824; 425823->425824; 425824->425825; 425825->425826; 425826->425827; }
425794,425795
425821,425822
Event Timeline
Enable zooming
Tasks: 30. 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