4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 1369 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.5 s
Locality Level Summary:
Node local: 8
Shuffle Read Size / Records:
105.2 KiB / 780
Shuffle Write Size / Records:
69.8 KiB / 363
Associated Job Ids:
639
DAG Visualization
digraph G { id="graph_1369"; subgraph graph_stage_1369 { id="graph_stage_1369"; isCluster="true"; label="Stage 1369"; subgraph cluster_11249 { id="cluster_11249"; isCluster="true"; label="Exchange"; 3538 [id="node_3538" labelType="html" label="ShuffledRowRDD [3538] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11246 { id="cluster_11246"; isCluster="true"; label="WholeStageCodegen (4)"; 3539 [id="node_3539" labelType="html" label="MapPartitionsRDD [3539] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11269 { id="cluster_11269"; isCluster="true"; label="Exchange"; 3545 [id="node_3545" labelType="html" label="ShuffledRowRDD [3545] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11266 { id="cluster_11266"; isCluster="true"; label="WholeStageCodegen (7)"; 3546 [id="node_3546" labelType="html" label="MapPartitionsRDD [3546] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11242 { id="cluster_11242"; isCluster="true"; label="WholeStageCodegen (8)"; 3547 [id="node_3547" labelType="html" label="ZippedPartitionsRDD2 [3547] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; 3548 [id="node_3548" labelType="html" label="MapPartitionsRDD [3548] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11241 { id="cluster_11241"; isCluster="true"; label="ObjectHashAggregate"; 3549 [id="node_3549" labelType="html" label="MapPartitionsRDD [3549] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11240 { id="cluster_11240"; isCluster="true"; label="Exchange"; 3550 [id="node_3550" labelType="html" label="MapPartitionsRDD [3550] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } } 3538->3539; 3545->3546; 3539->3547; 3546->3547; 3547->3548; 3548->3549; 3549->3550; }
3537,3538
3544,3545
Event Timeline
Enable zooming
Tasks: 8. 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