4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 1656903 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
13 s
Locality Level Summary:
Node local: 30
Output Size / Records:
1398.0 KiB / 35084
Shuffle Read Size / Records:
2.4 MiB / 70168
Associated Job Ids:
86110
DAG Visualization
digraph G { id="graph_1656903"; subgraph graph_stage_1656903 { id="graph_stage_1656903"; isCluster="true"; label="Stage 1656903"; subgraph cluster_1780388 { id="cluster_1780388"; isCluster="true"; label="Exchange"; 710162 [id="node_710162" labelType="html" label="ShuffledRowRDD [710162] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1780385 { id="cluster_1780385"; isCluster="true"; label="WholeStageCodegen (2)"; 710163 [id="node_710163" labelType="html" label="MapPartitionsRDD [710163] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1780400 { id="cluster_1780400"; isCluster="true"; label="Exchange"; 710168 [id="node_710168" labelType="html" label="ShuffledRowRDD [710168] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1780396 { id="cluster_1780396"; isCluster="true"; label="WholeStageCodegen (4)"; 710169 [id="node_710169" labelType="html" label="MapPartitionsRDD [710169] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1780381 { id="cluster_1780381"; isCluster="true"; label="WholeStageCodegen (5)"; 710170 [id="node_710170" labelType="html" label="ZippedPartitionsRDD2 [710170] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; 710171 [id="node_710171" labelType="html" label="MapPartitionsRDD [710171] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } } 710162->710163; 710168->710169; 710163->710170; 710169->710170; 710170->710171; }
710161,710162
710167,710168
710162
710163
710170
710171
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