4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 1308 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.6 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:
620
DAG Visualization
digraph G { id="graph_1308"; subgraph graph_stage_1308 { id="graph_stage_1308"; isCluster="true"; label="Stage 1308"; subgraph cluster_10822 { id="cluster_10822"; isCluster="true"; label="Exchange"; 3361 [id="node_3361" labelType="html" label="ShuffledRowRDD [3361] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_10819 { id="cluster_10819"; isCluster="true"; label="WholeStageCodegen (4)"; 3362 [id="node_3362" labelType="html" label="MapPartitionsRDD [3362] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_10848 { id="cluster_10848"; isCluster="true"; label="Exchange"; 3368 [id="node_3368" labelType="html" label="ShuffledRowRDD [3368] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_10845 { id="cluster_10845"; isCluster="true"; label="WholeStageCodegen (7)"; 3369 [id="node_3369" labelType="html" label="MapPartitionsRDD [3369] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_10815 { id="cluster_10815"; isCluster="true"; label="WholeStageCodegen (8)"; 3370 [id="node_3370" labelType="html" label="ZippedPartitionsRDD2 [3370] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; 3371 [id="node_3371" labelType="html" label="MapPartitionsRDD [3371] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_10814 { id="cluster_10814"; isCluster="true"; label="ObjectHashAggregate"; 3372 [id="node_3372" labelType="html" label="MapPartitionsRDD [3372] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_10813 { id="cluster_10813"; isCluster="true"; label="Exchange"; 3373 [id="node_3373" labelType="html" label="MapPartitionsRDD [3373] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } } 3361->3362; 3368->3369; 3362->3370; 3369->3370; 3370->3371; 3371->3372; 3372->3373; }
3360,3361
3367,3368
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