4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 1656539 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
16 s
Locality Level Summary:
Node local: 30
Shuffle Read Size / Records:
1692.4 KiB / 70168
Shuffle Write Size / Records:
1940.0 KiB / 17065
Associated Job Ids:
86101
DAG Visualization
digraph G { id="graph_1656539"; subgraph graph_stage_1656539 { id="graph_stage_1656539"; isCluster="true"; label="Stage 1656539"; subgraph cluster_1780080 { id="cluster_1780080"; isCluster="true"; label="Exchange"; 710054 [id="node_710054" labelType="html" label="ShuffledRowRDD [710054] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1780077 { id="cluster_1780077"; isCluster="true"; label="WholeStageCodegen (7)"; 710055 [id="node_710055" labelType="html" label="MapPartitionsRDD [710055] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1780118 { id="cluster_1780118"; isCluster="true"; label="Exchange"; 710060 [id="node_710060" labelType="html" label="ShuffledRowRDD [710060] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1780114 { id="cluster_1780114"; isCluster="true"; label="WholeStageCodegen (9)"; 710061 [id="node_710061" labelType="html" label="MapPartitionsRDD [710061] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1780073 { id="cluster_1780073"; isCluster="true"; label="WholeStageCodegen (10)"; 710062 [id="node_710062" labelType="html" label="ZippedPartitionsRDD2 [710062] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; 710063 [id="node_710063" labelType="html" label="MapPartitionsRDD [710063] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1780072 { id="cluster_1780072"; isCluster="true"; label="ObjectHashAggregate"; 710064 [id="node_710064" labelType="html" label="MapPartitionsRDD [710064] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1780071 { id="cluster_1780071"; isCluster="true"; label="Exchange"; 710065 [id="node_710065" labelType="html" label="MapPartitionsRDD [710065] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } } 710054->710055; 710060->710061; 710055->710062; 710061->710062; 710062->710063; 710063->710064; 710064->710065; }
710053,710054
710059,710060
710054
710055
710062
710063
710064
710065
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