4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 190883 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
22 s
Locality Level Summary:
Node local: 30
Shuffle Read Size / Records:
42.1 MiB / 445104
Shuffle Write Size / Records:
33.6 MiB / 218936
Associated Job Ids:
52720
DAG Visualization
digraph G { id="graph_190883"; subgraph graph_stage_190883 { id="graph_stage_190883"; isCluster="true"; label="Stage 190883"; subgraph cluster_1111307 { id="cluster_1111307"; isCluster="true"; label="Exchange"; 425260 [id="node_425260" labelType="html" label="ShuffledRowRDD [425260] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111304 { id="cluster_1111304"; isCluster="true"; label="WholeStageCodegen (9)"; 425261 [id="node_425261" labelType="html" label="MapPartitionsRDD [425261] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111356 { id="cluster_1111356"; isCluster="true"; label="Exchange"; 425287 [id="node_425287" labelType="html" label="ShuffledRowRDD [425287] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111353 { id="cluster_1111353"; isCluster="true"; label="WholeStageCodegen (17)"; 425288 [id="node_425288" labelType="html" label="MapPartitionsRDD [425288] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111300 { id="cluster_1111300"; isCluster="true"; label="WholeStageCodegen (18)"; 425289 [id="node_425289" labelType="html" label="ZippedPartitionsRDD2 [425289] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 425290 [id="node_425290" labelType="html" label="MapPartitionsRDD [425290] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111299 { id="cluster_1111299"; isCluster="true"; label="ObjectHashAggregate"; 425291 [id="node_425291" labelType="html" label="MapPartitionsRDD [425291] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111298 { id="cluster_1111298"; isCluster="true"; label="Exchange"; 425292 [id="node_425292" labelType="html" label="MapPartitionsRDD [425292] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 425260->425261; 425287->425288; 425261->425289; 425288->425289; 425289->425290; 425290->425291; 425291->425292; }
425259,425260
425286,425287
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